Skip to content

Commit 57acaeb

Browse files
committed
Fix NPE when DolphinScheduler build NULL parameters.
1 parent 6e65cd6 commit 57acaeb

File tree

1 file changed

+4
-1
lines changed
  • plugins/dolphinscheduler/dss-dolphinscheduler-client/src/main/scala/com/webank/wedatasphere/dss/plugins/dolphinscheduler/linkis/client/job

1 file changed

+4
-1
lines changed

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

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,8 +36,11 @@ class DolphinSchedulerJobBuilder(jobProps: JMap[String, String]) extends Builder
3636
val paramsMap = JsonUtils.jackson.readValue(jobParams, classOf[util.Map[String, Object]])
3737
linkisJob.setConfiguration(getConfiguration(paramsMap))
3838
linkisJob.setVariables(getVariables(paramsMap))
39-
linkisJob.getVariables.put("run_date", jobProps.get(LinkisJobTypeConf.RUN_DATE))
4039
}
40+
val runDate = new util.HashMap[String, Object]
41+
runDate.put("run_date", jobProps.get(LinkisJobTypeConf.RUN_DATE))
42+
linkisJob.setVariables(runDate)
43+
4144
val source = getSource
4245
linkisJob.setSource(source)
4346
linkisJob.getRuntimeParams.put("nodeName", source.get("nodeName"))

0 commit comments

Comments
 (0)