[INLONG-9532][Sort] Fix the wrong params for HudiExtractNode (#9535)

apache · Dec 27, 2023 · 66437de · 66437de
1 parent 452b326
commit 66437de
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...rt-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/HudiExtractNode.java b/...rt-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/HudiExtractNode.java
@@ -159,8 +159,8 @@ public Map<String, String> tableOptions() {
         options.put(HUDI_OPTION_DEFAULT_PATH, path);
 
         // read options
-        options.put(READ_START_COMMIT, String.valueOf(readStreamingSkipCompaction));
-        options.put(READ_STREAMING_SKIP_COMPACT, readStartCommit);
+        options.put(READ_START_COMMIT, readStartCommit);
+        options.put(READ_STREAMING_SKIP_COMPACT, String.valueOf(readStreamingSkipCompaction));
 
         options.put(HUDI_OPTION_DATABASE_NAME, dbName);
         options.put(HUDI_OPTION_TABLE_NAME, tableName);