fix

Ceng23333 · Nov 4, 2024 · cef7920 · cef7920
2 parents 0371d6d + 4630749
commit cef7920
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/lakesoul-flink/src/main/java/org/apache/flink/lakesoul/entry/sql/flink/ExecuteSql.java b/lakesoul-flink/src/main/java/org/apache/flink/lakesoul/entry/sql/flink/ExecuteSql.java
@@ -97,6 +97,9 @@ public static void executeSqlFileContent(String script, StreamTableEnvironment t
             System.out.println("There's no INSERT INTO statement, the program will terminate");
         }
 
+        // try get k8s cluster name
+        String k8sClusterID = conf.getString("kubernetes.cluster-id", "");
+        env.execute(k8sClusterID.isEmpty() ? null : k8sClusterID);
     }
 
     public static List<String> parseStatements(String script) {