Browse Source

[Fix][data-quality] change data-quality task main jar path (#8752)

* feat(data-quality) change data-quality task main jar path

* feat(data-quality) change data-quality task main jar path

Co-authored-by: zixi0825 <sunzhaohe@linklogis.com>
3.0.0/version-upgrade
zixi0825 3 years ago committed by GitHub
parent
commit
6a02b15e40
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 2
      dolphinscheduler-common/src/main/resources/common.properties
  2. 3
      dolphinscheduler-task-plugin/dolphinscheduler-task-dataquality/src/main/java/org/apache/dolphinscheduler/plugin/task/dq/DataQualityTask.java

2
dolphinscheduler-common/src/main/resources/common.properties

@ -76,7 +76,7 @@ datasource.encryption.enable=false
datasource.encryption.salt=!@#$%^&* datasource.encryption.salt=!@#$%^&*
# data quality option # data quality option
data-quality.jar.name=/worker-server/libs/dolphinscheduler-data-quality-2.0.4-SNAPSHOT.jar data-quality.jar.name=dolphinscheduler-data-quality-2.0.4-SNAPSHOT.jar
#data-quality.error.output.path=/tmp/data-quality-error-data #data-quality.error.output.path=/tmp/data-quality-error-data

3
dolphinscheduler-task-plugin/dolphinscheduler-task-dataquality/src/main/java/org/apache/dolphinscheduler/plugin/task/dq/DataQualityTask.java

@ -180,7 +180,8 @@ public class DataQualityTask extends AbstractYarnTask {
@Override @Override
protected void setMainJarName() { protected void setMainJarName() {
ResourceInfo mainJar = new ResourceInfo(); ResourceInfo mainJar = new ResourceInfo();
mainJar.setRes(CommonUtils.getDataQualityJarName()); String basePath = System.getProperty("user.dir").replace(File.separator + "bin", File.separator + "libs");
mainJar.setRes(basePath + File.separator + CommonUtils.getDataQualityJarName());
dataQualityParameters.getSparkParameters().setMainJar(mainJar); dataQualityParameters.getSparkParameters().setMainJar(mainJar);
} }

Loading…
Cancel
Save