From 9fc2a317daa1f88a51840d6daaa0608361287886 Mon Sep 17 00:00:00 2001 From: haibo-duan Date: Fri, 15 Mar 2024 13:59:11 +0800 Subject: [PATCH] [INLONG-9755][Sort] fix bug --- .../config/loader/ClassResourceQueryConsumeConfig.java | 1 + 1 file changed, 1 insertion(+) diff --git a/inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/config/loader/ClassResourceQueryConsumeConfig.java b/inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/config/loader/ClassResourceQueryConsumeConfig.java index dd0f4b32ec..570c437efb 100644 --- a/inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/config/loader/ClassResourceQueryConsumeConfig.java +++ b/inlong-sort-standalone/sort-standalone-common/src/main/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); } }