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 index ffb4f9c78f7f5..98bf8a6f332ec 100644 --- 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 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 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",