[fixed] fixed envsetting unload flink-conf.yaml,if not like catalogst…

…ore conf will not work
apache · Oct 5, 2024 · f73253b · f73253b
1 parent cee932b
commit f73253b
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...nk-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala b/...nk-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala
@@ -118,6 +118,12 @@ private[flink] class FlinkTableInitializer(args: Array[String], apiType: ApiType
         }
     }
 
+    parameter.get(KEY_FLINK_CONF(), null) match {
+      case null | "" =>
+        throw new ExceptionInInitializerError(
+          "[StreamPark] Usage:can't find config,please set \"--flink.conf $conf \" in main arguments")
+      case conf => builder.withConfiguration(Configuration.fromMap(PropertiesUtils.fromYamlText(DeflaterUtils.unzipString(conf))) status)
+    }
     val buildWith =
       (parameter.get(KEY_FLINK_TABLE_CATALOG), parameter.get(KEY_FLINK_TABLE_DATABASE))
     buildWith match {