[flink] create table validate options

apache · Aug 6, 2024 · 4b4becd · 4b4becd
1 parent edda6b9
commit 4b4becd
Showing 1 changed file with 12 additions and 8 deletions.
diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java
@@ -18,8 +18,6 @@
 
 package org.apache.paimon.flink;
 
-import java.util.Arrays;
-import java.util.HashSet;
 import org.apache.paimon.CoreOptions;
 import org.apache.paimon.catalog.Catalog;
 import org.apache.paimon.catalog.Identifier;
@@ -95,8 +93,10 @@
 
 import java.time.Duration;
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.Collections;
 import java.util.HashMap;
+import java.util.HashSet;
 import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
@@ -350,13 +350,17 @@ private void validateOptions(Map<String, String> options) {
                                 })
                         .collect(Collectors.toSet());
 
-        Set<String> additionalValidOptions = new HashSet<>(Arrays.asList("is_streaming", "connector", "log.system"));
+        Set<String> additionalValidOptions =
+                new HashSet<>(Arrays.asList("is_streaming", "connector", "log.system"));
 
-        options.keySet().forEach(optionKey -> {
-            if (!validOptions.contains(optionKey) && !additionalValidOptions.contains(optionKey)) {
-                throw new IllegalArgumentException("Invalid option: " + optionKey);
-            }
-        });
+        options.keySet()
+                .forEach(
+                        optionKey -> {
+                            if (!validOptions.contains(optionKey)
+                                    && !additionalValidOptions.contains(optionKey)) {
+                                throw new IllegalArgumentException("Invalid option: " + optionKey);
+                            }
+                        });
     }
 
     protected Schema buildPaimonSchema(