[flink] create table validate options

apache · Aug 7, 2024 · 4c1d175 · 4c1d175
1 parent 8972833
commit 4c1d175
Showing 1 changed file with 5 additions and 2 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
@@ -24,6 +24,8 @@
 import org.apache.paimon.data.BinaryRow;
 import org.apache.paimon.flink.procedure.ProcedureUtil;
 import org.apache.paimon.flink.utils.FlinkCatalogPropertiesUtil;
+import org.apache.paimon.format.OrcOptions;
+import org.apache.paimon.lookup.RocksDBOptions;
 import org.apache.paimon.options.ConfigOption;
 import org.apache.paimon.options.Options;
 import org.apache.paimon.schema.Schema;
@@ -341,7 +343,9 @@ private static void validateOptions(Map<String, String> options) {
                 Stream.of(
                                 CoreOptions.class.getFields(),
                                 FlinkConnectorOptions.class.getFields(),
-                                FlinkCatalogOptions.class.getFields())
+                                FlinkCatalogOptions.class.getFields(),
+                                OrcOptions.class.getFields(),
+                                RocksDBOptions.class.getFields())
                         .flatMap(Stream::of)
                         .filter(field -> java.lang.reflect.Modifier.isStatic(field.getModifiers()))
                         .filter(field -> ConfigOption.class.isAssignableFrom(field.getType()))
@@ -367,7 +371,6 @@ private static void validateOptions(Map<String, String> options) {
                                 "kafka.topic",
                                 "kafka.transaction.timeout.ms",
                                 "kafka.batch.size",
-                                "rocksdb.compaction.level.target-file-size-base",
                                 "file-index.bloom-filter.columns",
                                 "file-index.bloom-filter.indexc.items",
                                 "a.aa.aaa",