Skip to content

Commit 7b59b19

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

File tree

1 file changed

+2
-1
lines changed
  • streamis-jobmanager/streamis-job-manager/streamis-job-manager-service/src/main/scala/com/webank/wedatasphere/streamis/jobmanager/manager/transform/impl

1 file changed

+2
-1
lines changed

streamis-jobmanager/streamis-job-manager/streamis-job-manager-service/src/main/scala/com/webank/wedatasphere/streamis/jobmanager/manager/transform/impl/FlinkInternalConfigTransform.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
package com.webank.wedatasphere.streamis.jobmanager.manager.transform.impl
2+
import com.webank.wedatasphere.streamis.jobmanager.launcher.conf.JobConfKeyConstants
23
import com.webank.wedatasphere.streamis.jobmanager.launcher.job.LaunchJob
34
import com.webank.wedatasphere.streamis.jobmanager.manager.conf.JobConf
45
import com.webank.wedatasphere.streamis.jobmanager.manager.transform.impl.FlinkInternalConfigTransform.INTERNAL_CONFIG_MAP
@@ -17,7 +18,7 @@ class FlinkInternalConfigTransform extends FlinkConfigTransform {
1718
*
1819
* @return
1920
*/
20-
override protected def configGroup(): String = JobConf.STREAMIS_INTERNAL_CONFIG_GROUP.getValue
21+
override protected def configGroup(): String = JobConfKeyConstants.GROUP_INTERNAL.getValue
2122

2223
override protected def transform(internalConfig: util.Map[String, Any], job: LaunchJob): LaunchJob = {
2324
transformConfig(internalConfig.asScala.map{

0 commit comments

Comments
 (0)