Skip to content

Commit 889d8e4

Browse files
Fix the NPE of DolphinSchedulerAppConnLinkisJob.
1 parent b8395fe commit 889d8e4

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

plugins/dolphinscheduler/dss-dolphinscheduler-client/src/main/scala/com/webank/wedatasphere/dss/plugins/dolphinscheduler/linkis/client/job/DolphinSchedulerAppConnLinkisJob.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,11 @@ package com.webank.wedatasphere.dss.plugins.dolphinscheduler.linkis.client.job
22

33
import com.webank.wedatasphere.dss.linkis.node.execution.job.AbstractAppConnLinkisJob
44
import com.webank.wedatasphere.dss.plugins.dolphinscheduler.linkis.client.conf.LinkisJobTypeConf
5+
import org.apache.commons.lang3.StringUtils
56

67
class DolphinSchedulerAppConnLinkisJob extends AbstractAppConnLinkisJob {
7-
override def getSubmitUser: String = if (getJobProps.get(LinkisJobTypeConf.FLOW_SUBMIT_USER).isEmpty) getJobProps.get(LinkisJobTypeConf.PROXY_USER) else getJobProps.get(LinkisJobTypeConf.FLOW_SUBMIT_USER)
8+
override def getSubmitUser: String = if (StringUtils.isBlank(getJobProps.get(LinkisJobTypeConf.FLOW_SUBMIT_USER)))
9+
getJobProps.get(LinkisJobTypeConf.PROXY_USER) else getJobProps.get(LinkisJobTypeConf.FLOW_SUBMIT_USER)
810

911
override def getUser: String = getJobProps.get(LinkisJobTypeConf.PROXY_USER)
1012

0 commit comments

Comments
 (0)