fix

vernedeng · Jul 1, 2024 · 55f1f69 · 55f1f69
1 parent 630369f
commit 55f1f69
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/...alone-source/src/main/java/org/apache/inlong/sort/standalone/sink/cls/ClsSinkContext.java b/...alone-source/src/main/java/org/apache/inlong/sort/standalone/sink/cls/ClsSinkContext.java
@@ -116,7 +116,7 @@ public void reload() {
             this.sortTaskConfig = newSortTaskConfig;
 
             Map<String, ClsIdConfig> fromTaskConfig = reloadIdParamsFromTaskConfig(taskConfig, clsNodeConfig);
-            Map<String, ClsIdConfig> fromSortTaskConfig = reloadIdParamsFromTaskConfig(sortTaskConfig);
+            Map<String, ClsIdConfig> fromSortTaskConfig = reloadIdParamsFromSortTaskConfig(sortTaskConfig);
             idConfigMap = unifiedConfiguration ? fromTaskConfig : fromSortTaskConfig;
             this.reloadClients(idConfigMap);
             this.reloadHandler();
@@ -156,15 +156,13 @@ private Map<String, ClsIdConfig> reloadIdParamsFromTaskConfig(TaskConfig taskCon
                         v -> v));
     }
 
-    private Map<String, ClsIdConfig> reloadIdParamsFromTaskConfig(SortTaskConfig sortTaskConfig)
+    private Map<String, ClsIdConfig> reloadIdParamsFromSortTaskConfig(SortTaskConfig sortTaskConfig)
             throws JsonProcessingException {
         if (sortTaskConfig == null) {
             return new HashMap<>();
         }
         List<Map<String, String>> idList = this.sortTaskConfig.getIdParams();
         Map<String, ClsIdConfig> newIdConfigMap = new ConcurrentHashMap<>();
-        ObjectMapper objectMapper = new ObjectMapper();
-        objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
         for (Map<String, String> idParam : idList) {
             String inlongGroupId = idParam.get(Constants.INLONG_GROUP_ID);
             String inlongStreamId = idParam.get(Constants.INLONG_STREAM_ID);