From 1d9bc0cd74b9aea573e222cecce8a96e6cc329bd Mon Sep 17 00:00:00 2001 From: t1mon <178317391@qq.com> Date: Sat, 28 Mar 2020 17:42:33 +0800 Subject: [PATCH] Fix SqlTask kerberos load scope unreasonable. #2178 (#2321) * Optimize PropertyUtils instantiation. * Fix info error. * Fix SqlTask kerberos load scope unreasonable. #2178 --- .../dolphinscheduler/server/worker/task/sql/SqlTask.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java index 2fed0f7bc4..34b87fff79 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sql/SqlTask.java @@ -25,6 +25,7 @@ import org.apache.commons.lang.StringUtils; import org.apache.dolphinscheduler.alert.utils.MailUtils; import org.apache.dolphinscheduler.common.Constants; import org.apache.dolphinscheduler.common.enums.AuthorizationType; +import org.apache.dolphinscheduler.common.enums.DbType; import org.apache.dolphinscheduler.common.enums.ShowType; import org.apache.dolphinscheduler.common.enums.TaskTimeoutStrategy; import org.apache.dolphinscheduler.common.enums.UdfType; @@ -257,11 +258,12 @@ public class SqlTask extends AbstractTask { List createFuncs){ Connection connection = null; try { - // if upload resource is HDFS and kerberos startup - CommonUtils.loadKerberosConf(); // if hive , load connection params if exists - if (HIVE == dataSource.getType()) { + if (DbType.HIVE == dataSource.getType() || DbType.SPARK == dataSource.getType()) { + // if upload resource is HDFS and kerberos startup + CommonUtils.loadKerberosConf(); + Properties paramProp = new Properties(); paramProp.setProperty(USER, baseDataSource.getUser()); paramProp.setProperty(PASSWORD, baseDataSource.getPassword());