[INLONG-9543][Dashboard] Cls, Pulsar and es sink support saving sortT…

…askName and sortConsumerGroup
bluewang · Dec 28, 2023 · 3acfefe · 3acfefe
1 parent 869aeb0
commit 3acfefe
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 0 deletions.
diff --git a/inlong-dashboard/src/ui/pages/GroupDetail/DataStorage/DetailModal.tsx b/inlong-dashboard/src/ui/pages/GroupDetail/DataStorage/DetailModal.tsx
@@ -158,6 +158,14 @@ const Comp: React.FC<DetailModalProps> = ({
     if (startProcess) {
       submitData.startProcess = true;
     }
+    if (
+      submitData.sinkType === 'CLS' ||
+      submitData.sinkType === 'PULSAR' ||
+      submitData.sinkType === 'ES'
+    ) {
+      submitData.sortTaskName = submitData.dataNodeName;
+      submitData.sortConsumerGroup = submitData.dataNodeName;
+    }
     await request({
       url: isUpdate ? '/sink/update' : '/sink/save',
       method: 'POST',

diff --git a/inlong-dashboard/src/ui/pages/SynchronizeDetail/SyncSink/DetailModal.tsx b/inlong-dashboard/src/ui/pages/SynchronizeDetail/SyncSink/DetailModal.tsx
@@ -135,6 +135,14 @@ const Comp: React.FC<DetailModalProps> = ({
       submitData.id = id;
       submitData.version = data?.version;
     }
+    if (
+      submitData.sinkType === 'CLS' ||
+      submitData.sinkType === 'PULSAR' ||
+      submitData.sinkType === 'ES'
+    ) {
+      submitData.sortTaskName = submitData.dataNodeName;
+      submitData.sortConsumerGroup = submitData.dataNodeName;
+    }
     const sinkData = Object.assign(submitData, createData);
     await request({
       url: isUpdate ? '/sink/update' : '/sink/save',