(inlong) branch master updated: [INLONG-11982][Sort] Fix Null Point Exception when changelogAuditKey is not set (#11983)

[vernedeng]

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

vernedeng 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 4da76bb9da [INLONG-11982][Sort] Fix Null Point Exception when 
changelogAuditKey is not set (#11983)
4da76bb9da is described below

commit 4da76bb9dae933697b9773c5bf19a003bd2ef112
Author: vernedeng <verned...@apache.org>
AuthorDate: Thu Sep 4 17:31:24 2025 +0800

    [INLONG-11982][Sort] Fix Null Point Exception when changelogAuditKey is not 
set (#11983)
---
 .../src/main/java/org/apache/inlong/sort/util/AuditUtils.java        | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/util/AuditUtils.java
 
b/inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/util/AuditUtils.java
index 7c647c37c5..a1fad205ec 100644
--- 
a/inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/util/AuditUtils.java
+++ 
b/inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/util/AuditUtils.java
@@ -19,6 +19,8 @@ package org.apache.inlong.sort.util;
 
 import com.google.common.base.Preconditions;
 import com.google.common.base.Splitter;
+import com.google.common.collect.ImmutableMap;
+import org.apache.commons.lang3.StringUtils;
 import org.apache.flink.types.RowKind;
 
 import java.util.Arrays;
@@ -56,6 +58,9 @@ public class AuditUtils {
     }
 
     public static Map<RowKind, Integer> extractChangelogAuditKeyMap(String 
changelogAuditKeys) {
+        if (StringUtils.isBlank(changelogAuditKeys)) {
+            return ImmutableMap.of();
+        }
         return 
Splitter.on("&").withKeyValueSeparator("=").split(changelogAuditKeys)
                 .entrySet()
                 .stream()