[flink] create table validate options

apache · Aug 7, 2024 · 1fa3b37 · 1fa3b37
1 parent b0adcdf
commit 1fa3b37
Showing 1 changed file with 2 additions 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
@@ -387,7 +387,8 @@ private static Set<String> getValidOptions() {
         try {
             Class<?> rocksDBOptionsClass = Class.forName("org.apache.paimon.lookup.RocksDBOptions");
             rocksDBOptionsFields = Stream.of(rocksDBOptionsClass.getFields());
-        } catch (ClassNotFoundException e) {
+        } catch (Exception e) {
+            // RocksDBOptions class not found.
             rocksDBOptionsFields = Stream.empty();
         }