[flink] create table validate options

apache · Aug 7, 2024 · 91c0f22 · 91c0f22
1 parent 393e197
commit 91c0f22
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -385,7 +385,7 @@ private static Set<String> getValidOptions() {
 
         Stream<Field> rocksDBOptionsFields;
         try {
-            Class<?> rocksDBOptionsClass = Class.forName("RocksDBOptions");
+            Class<?> rocksDBOptionsClass = Class.forName("org.apache.paimon.lookup.RocksDBOptions");
             rocksDBOptionsFields = Stream.of(rocksDBOptionsClass.getFields());
         } catch (ClassNotFoundException e) {
             rocksDBOptionsFields = Stream.empty();