We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e79e906 commit 4da76bbCopy full SHA for 4da76bb
1 file changed
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/util/AuditUtils.java
@@ -19,6 +19,8 @@
19
20
import com.google.common.base.Preconditions;
21
import com.google.common.base.Splitter;
22
+import com.google.common.collect.ImmutableMap;
23
+import org.apache.commons.lang3.StringUtils;
24
import org.apache.flink.types.RowKind;
25
26
import java.util.Arrays;
@@ -56,6 +58,9 @@ public static List<Integer> extractAuditKeys(String auditKeys) {
56
58
}
57
59
60
public static Map<RowKind, Integer> extractChangelogAuditKeyMap(String changelogAuditKeys) {
61
+ if (StringUtils.isBlank(changelogAuditKeys)) {
62
+ return ImmutableMap.of();
63
+ }
64
return Splitter.on("&").withKeyValueSeparator("=").split(changelogAuditKeys)
65
.entrySet()
66
.stream()
0 commit comments