fix

vernedeng · Jun 21, 2024 · 0b4efcd · 0b4efcd
1 parent cf4d1ce
commit 0b4efcd
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/...rvice/src/main/java/org/apache/inlong/manager/service/tenant/InlongTenantServiceImpl.java b/...rvice/src/main/java/org/apache/inlong/manager/service/tenant/InlongTenantServiceImpl.java
@@ -271,10 +271,7 @@ public Boolean migrateStreamSink(StreamSinkEntity sink, String from, String to)
         }
 
         String newName = copyDataNode(dataNodeName, type, from, to);
-        sink.setDataNodeName(newName);
-        sink.setSortConsumerGroup(newName);
-        sink.setSortTaskName(newName);
-        return sinkMapper.updateByIdSelective(sink) == InlongConstants.AFFECTED_ONE_ROW;
+        return StringUtils.isNotEmpty(newName);
 
     }