Skip to content

Commit 63020bc

Browse files
committed
Fix the problem in job builder.
1 parent f8dcb52 commit 63020bc

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

streamis-jobmanager/streamis-job-manager/streamis-job-manager-service/src/main/scala/com/webank/wedatasphere/streamis/jobmanager/manager/transform/builder/AbstractStreamisTransformJobBuilder.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,8 +45,9 @@ abstract class AbstractStreamisTransformJobBuilder extends StreamisTransformJobB
4545
val jobConfig: util.Map[String, Any] = Option(streamJobConfService.getJobConfig(streamJob.getId))
4646
.getOrElse(new util.HashMap[String, Any]())
4747
// Put and overwrite internal group, users cannot customize the internal configuration
48-
jobConfig.put(JobConf.STREAMIS_INTERNAL_CONFIG_GROUP.getValue, new util.HashMap[String, Any]())
49-
internalLogConfig(jobConfig)
48+
val internalGroup = new util.HashMap[String, Any]()
49+
jobConfig.put(JobConf.STREAMIS_INTERNAL_CONFIG_GROUP.getValue, internalGroup)
50+
internalLogConfig(internalGroup)
5051
transformJob.setConfigMap(jobConfig)
5152
// transformJob.setConfig(configurationService.getFullTree(streamJob.getId))
5253
val streamJobVersions = streamJobMapper.getJobVersions(streamJob.getId)

0 commit comments

Comments
 (0)