[INLONG-9755][Sort] fix bug

haibo-duan · Mar 15, 2024 · 9fc2a31 · 9fc2a31
1 parent edc58b5
commit 9fc2a31
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...java/org/apache/inlong/sort/standalone/config/loader/ClassResourceQueryConsumeConfig.java b/...java/org/apache/inlong/sort/standalone/config/loader/ClassResourceQueryConsumeConfig.java
@@ -73,6 +73,7 @@ public ConsumeConfig queryCurrentConsumeConfig(String sortTaskId) {
                     topic.setInLongCluster(cacheZoneCluster);
                     topic.setTopic(topicInfo.getTopic());
                     topic.setTopicType(cacheZone.getZoneType());
+                    topic.setProperties(topicInfo.getTopicProperties());
                     topics.add(topic);
                 }
             }