[core] fix comments.

apache · Jan 12, 2025 · 7250389 · 7250389
1 parent bffabba
commit 7250389
Showing 1 changed file with 11 additions and 6 deletions.
diff --git a/paimon-common/src/main/java/org/apache/paimon/CoreOptions.java b/paimon-common/src/main/java/org/apache/paimon/CoreOptions.java
@@ -2239,12 +2239,17 @@ public boolean writeOnly() {
     }
 
     public Set<WriteAction> writeSkippingActions() {
-        String str = options.get(WRITE_SKIP_ACTIONS);
-        return StringUtils.isNullOrWhitespaceOnly(str)
-                ? new HashSet<>(0)
-                : Arrays.stream(str.split(","))
-                        .map(action -> WriteAction.valueOf(action.toUpperCase().replace('-', '_')))
-                        .collect(Collectors.toCollection(HashSet::new));
+        return options.getOptional(WRITE_SKIP_ACTIONS)
+                .map(
+                        str ->
+                                Arrays.stream(str.split(","))
+                                        .map(
+                                                action ->
+                                                        WriteAction.valueOf(
+                                                                action.toUpperCase()
+                                                                        .replace('-', '_')))
+                                        .collect(Collectors.toCollection(HashSet::new)))
+                .orElseGet(() -> new HashSet<>(0));
     }
 
     public boolean skippingPartitionExpire(Set<WriteAction> skippingActions) {