From 1fa3b372f2a6b25f4be07920c2ebc6696d16a120 Mon Sep 17 00:00:00 2001 From: chenzhuoyu Date: Wed, 7 Aug 2024 11:51:49 +0800 Subject: [PATCH] [flink] create table validate options --- .../src/main/java/org/apache/paimon/flink/FlinkCatalog.java | 3 ++- 1 file changed, 2 insertions(+), 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 index 572e773952003..a641fe94378c9 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 @@ -387,7 +387,8 @@ private static Set 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(); }