From 6a02b15e40d04e98891276b0e4f78312de602436 Mon Sep 17 00:00:00 2001 From: zixi0825 <649790970@qq.com> Date: Wed, 9 Mar 2022 21:49:19 +0800 Subject: [PATCH] [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 --- dolphinscheduler-common/src/main/resources/common.properties | 2 +- .../dolphinscheduler/plugin/task/dq/DataQualityTask.java | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/dolphinscheduler-common/src/main/resources/common.properties b/dolphinscheduler-common/src/main/resources/common.properties index 199f7abfe1..b4c2a3211b 100644 --- a/dolphinscheduler-common/src/main/resources/common.properties +++ b/dolphinscheduler-common/src/main/resources/common.properties @@ -76,7 +76,7 @@ datasource.encryption.enable=false datasource.encryption.salt=!@#$%^&* # 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 diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-dataquality/src/main/java/org/apache/dolphinscheduler/plugin/task/dq/DataQualityTask.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-dataquality/src/main/java/org/apache/dolphinscheduler/plugin/task/dq/DataQualityTask.java index cae09cdcdc..e344995e36 100644 --- a/dolphinscheduler-task-plugin/dolphinscheduler-task-dataquality/src/main/java/org/apache/dolphinscheduler/plugin/task/dq/DataQualityTask.java +++ b/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 protected void setMainJarName() { 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); }