(inlong) branch master updated: [INLONG-11833][Sort] Appendmode configuration ignores case (#11834)

[dockerzhang]

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

dockerzhang 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 b170faf0a5 [INLONG-11833][Sort] Appendmode configuration ignores case 
(#11834)
b170faf0a5 is described below

commit b170faf0a54ccd05248fc4a430cc527034023e1e
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Thu Apr 17 13:15:39 2025 +0800

    [INLONG-11833][Sort] Appendmode configuration ignores case (#11834)
---
 .../java/org/apache/inlong/sort/protocol/node/load/IcebergLoadNode.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/IcebergLoadNode.java
 
b/inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/IcebergLoadNode.java
index 3b08fa490f..154d0c78b1 100644
--- 
a/inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/IcebergLoadNode.java
+++ 
b/inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/IcebergLoadNode.java
@@ -181,7 +181,7 @@ public class IcebergLoadNode extends LoadNode implements 
InlongMetric, Metadata,
         options.put(IcebergConstant.CATALOG_TYPE_KEY, catalogType.name());
         options.put(IcebergConstant.CATALOG_NAME_KEY, catalogType.name());
 
-        if ("upsert".equals(appendMode)) {
+        if ("upsert".equalsIgnoreCase(appendMode)) {
             options.put(IcebergConstant.UPSERT_ENABLED_KEY, 
Boolean.TRUE.toString());
         } else {
             options.put(IcebergConstant.UPSERT_ENABLED_KEY, 
Boolean.FALSE.toString());