(inlong) branch master updated: [INLONG-9756][Manager] Add separator between groupId and streamId in jobName (#9757)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new e92612664a [INLONG-9756][Manager] Add separator between groupId and 
streamId in jobName (#9757)
e92612664a is described below

commit e92612664ae7ca257aca5a82cb66cdf175362f37
Author: AloysZhang <aloyszh...@apache.org>
AuthorDate: Fri Mar 1 15:26:10 2024 +0800

    [INLONG-9756][Manager] Add separator between groupId and streamId in 
jobName (#9757)
---
 .../org/apache/inlong/manager/plugin/listener/RestartSortListener.java | 3 ++-
 .../org/apache/inlong/manager/plugin/listener/StartupSortListener.java | 3 ++-
 .../apache/inlong/manager/plugin/listener/StartupStreamListener.java   | 3 ++-
 3 files changed, 6 insertions(+), 3 deletions(-)

diff --git 
a/inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/RestartSortListener.java
 
b/inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/RestartSortListener.java
index 66bf88b149..9a95da354a 100644
--- 
a/inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/RestartSortListener.java
+++ 
b/inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/RestartSortListener.java
@@ -122,7 +122,8 @@ public class RestartSortListener implements 
SortOperateListener {
             }
 
             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/inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupSortListener.java
 
b/inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupSortListener.java
index d2894ad88f..8fa72f1c4b 100644
--- 
a/inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupSortListener.java
+++ 
b/inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupSortListener.java
@@ -133,7 +133,8 @@ public class StartupSortListener implements 
SortOperateListener {
 
             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/inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupStreamListener.java
 
b/inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupStreamListener.java
index b3a341c37d..99c0245168 100644
--- 
a/inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupStreamListener.java
+++ 
b/inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupStreamListener.java
@@ -126,7 +126,8 @@ public class StartupStreamListener implements 
SortOperateListener {
 
         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);