(inlong) branch master updated: [INLONG-9532][Sort] Fix the wrong params for HudiExtractNode (#9535)

[zirui]

This is an automated email from the ASF dual-hosted git repository.

zirui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 66437de503 [INLONG-9532][Sort] Fix the wrong params for 
HudiExtractNode (#9535)
66437de503 is described below

commit 66437de503b89f1ae31e0b09516b93efd95f4bfc
Author: Charles Zhang <dockerzh...@apache.org>
AuthorDate: Wed Dec 27 18:44:43 2023 +0800

    [INLONG-9532][Sort] Fix the wrong params for HudiExtractNode (#9535)
---
 .../org/apache/inlong/sort/protocol/node/extract/HudiExtractNode.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/HudiExtractNode.java
 
b/inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/HudiExtractNode.java
index 6b34a174c7..f70f1004c5 100644
--- 
a/inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/HudiExtractNode.java
+++ 
b/inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/HudiExtractNode.java
@@ -159,8 +159,8 @@ public class HudiExtractNode extends ExtractNode implements 
Serializable {
         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);