Skip to content

Commit 6fa37c7

Browse files
committed
Move the internal group config into JobConfKeyConstants.
1 parent 63020bc commit 6fa37c7

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

streamis-jobmanager/streamis-job-launcher/streamis-job-launcher-service/src/main/scala/com/webank/wedatasphere/streamis/jobmanager/launcher/conf/JobConfKeyConstants.scala

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,10 @@ import org.apache.linkis.common.conf.CommonVars
2323
*/
2424
object JobConfKeyConstants {
2525

26+
/**
27+
* Config group for streamis internal configuration
28+
*/
29+
val GROUP_INTERNAL: CommonVars[String] = CommonVars("wds.streamis.job.internal.config.group", "wds.streamis.internal.params")
2630
/**
2731
* Group: Flink extra
2832
*/

streamis-jobmanager/streamis-job-manager/streamis-job-manager-service/src/main/scala/com/webank/wedatasphere/streamis/jobmanager/manager/conf/JobConf.scala

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -29,11 +29,6 @@ object JobConf {
2929

3030
val STREAMIS_JOB_PARAM_BLANK_PLACEHOLDER: CommonVars[String] = CommonVars("wds.streamis.job.param.blank.placeholder", "\u0001")
3131

32-
/**
33-
* Config group for streamis internal configuration
34-
*/
35-
val STREAMIS_INTERNAL_CONFIG_GROUP: CommonVars[String] = CommonVars("wds.streamis.job.internal.config.group", "wds.streamis.internal.params")
36-
3732
/**
3833
* Gateway for stream job log module
3934
*/

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515

1616
package com.webank.wedatasphere.streamis.jobmanager.manager.transform.builder
1717

18+
import com.webank.wedatasphere.streamis.jobmanager.launcher.conf.JobConfKeyConstants
1819
import org.apache.linkis.common.conf.CommonVars
1920
import org.apache.linkis.manager.label.entity.engine.RunType.RunType
2021
import com.webank.wedatasphere.streamis.jobmanager.launcher.service.StreamJobConfService
@@ -46,7 +47,7 @@ abstract class AbstractStreamisTransformJobBuilder extends StreamisTransformJobB
4647
.getOrElse(new util.HashMap[String, Any]())
4748
// Put and overwrite internal group, users cannot customize the internal configuration
4849
val internalGroup = new util.HashMap[String, Any]()
49-
jobConfig.put(JobConf.STREAMIS_INTERNAL_CONFIG_GROUP.getValue, internalGroup)
50+
jobConfig.put(JobConfKeyConstants.GROUP_INTERNAL.getValue, internalGroup)
5051
internalLogConfig(internalGroup)
5152
transformJob.setConfigMap(jobConfig)
5253
// transformJob.setConfig(configurationService.getFullTree(streamJob.getId))

0 commit comments

Comments
 (0)