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

…jobName
apache · Mar 1, 2024 · 9acaa88 · 9acaa88
1 parent 896bb54
commit 9acaa88
Showing 1 changed file with 2 additions and 1 deletion.
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
@@ -46,6 +46,7 @@
 import java.util.Map;
 import java.util.stream.Collectors;
 
+import static org.apache.inlong.manager.common.consts.InlongConstants.HYPHEN;
 import static org.apache.inlong.manager.plugin.util.FlinkUtils.getExceptionStackMsg;
 
 /**
@@ -133,7 +134,7 @@ 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) + HYPHEN + streamInfo.getInlongStreamId();
             flinkInfo.setJobName(jobName);
             String sortUrl = kvConf.get(InlongConstants.SORT_URL);
             flinkInfo.setEndpoint(sortUrl);