[INLONG-9756][Manager] Add separator between groupId and streamId in …

…jobName (#9757)
apache · Mar 1, 2024 · e926126 · e926126
1 parent d1f84fe
commit e926126
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/...ins/base/src/main/java/org/apache/inlong/manager/plugin/listener/RestartSortListener.java b/...ins/base/src/main/java/org/apache/inlong/manager/plugin/listener/RestartSortListener.java
@@ -122,7 +122,8 @@ public ListenerResult listen(WorkflowContext context) throws Exception {
  }
 
  FlinkInfo flinkInfo = new FlinkInfo();
- String jobName = Constants.SORT_JOB_NAME_GENERATOR.apply(processForm) + streamInfo.getInlongStreamId();
+ String jobName = Constants.SORT_JOB_NAME_GENERATOR.apply(processForm) + InlongConstants.HYPHEN
+ + streamInfo.getInlongStreamId();
  flinkInfo.setJobName(jobName);
  String sortUrl = kvConf.get(InlongConstants.SORT_URL);
  flinkInfo.setEndpoint(sortUrl);

diff --git a/...ins/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupSortListener.java b/...ins/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupSortListener.java
@@ -133,7 +133,8 @@ public ListenerResult listen(WorkflowContext context) throws Exception {
 
  FlinkInfo flinkInfo = new FlinkInfo();
 
- String jobName = Constants.SORT_JOB_NAME_GENERATOR.apply(processForm) + streamInfo.getInlongStreamId();
+ String jobName = Constants.SORT_JOB_NAME_GENERATOR.apply(processForm) + InlongConstants.HYPHEN
+ + streamInfo.getInlongStreamId();
  flinkInfo.setJobName(jobName);
  String sortUrl = kvConf.get(InlongConstants.SORT_URL);
  flinkInfo.setEndpoint(sortUrl);

diff --git a/...s/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupStreamListener.java b/...s/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupStreamListener.java
@@ -126,7 +126,8 @@ public ListenerResult listen(WorkflowContext context) throws Exception {
 
  FlinkInfo flinkInfo = new FlinkInfo();
 
- String jobName = Constants.SORT_JOB_NAME_GENERATOR.apply(processForm) + streamInfo.getInlongStreamId();
+ String jobName = Constants.SORT_JOB_NAME_GENERATOR.apply(processForm) + InlongConstants.HYPHEN
+ + streamInfo.getInlongStreamId();
  flinkInfo.setJobName(jobName);
  String sortUrl = kvConf.get(InlongConstants.SORT_URL);
  flinkInfo.setEndpoint(sortUrl);