[FLINK-29188][sql-gateway][hive] Make option "sql-gateway.endpint.hiv…

…eserver2.catalog.hive-conf-dir" required
riptano · Sep 19, 2022 · c2305d0 · c2305d0
1 parent b37a815
commit c2305d0
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...r-hive/src/main/java/org/apache/flink/table/endpoint/hive/HiveServer2EndpointFactory.java b/...r-hive/src/main/java/org/apache/flink/table/endpoint/hive/HiveServer2EndpointFactory.java
@@ -80,7 +80,7 @@ public String factoryIdentifier() {
 
     @Override
     public Set<ConfigOption<?>> requiredOptions() {
-        return Collections.emptySet();
+        return Collections.singleton(CATALOG_HIVE_CONF_DIR);
     }
 
     @Override
@@ -95,7 +95,6 @@ public Set<ConfigOption<?>> optionalOptions() {
                         THRIFT_WORKER_THREADS_MAX,
                         THRIFT_WORKER_KEEPALIVE_TIME,
                         CATALOG_NAME,
-                        CATALOG_HIVE_CONF_DIR,
                         CATALOG_DEFAULT_DATABASE,
                         MODULE_NAME));
     }