fix application mode submit failed (#742)

53485855 · zhu-mingye · GitHub · 8120dd85 · 53485855
Unverified Commit 53485855 authored Jul 19, 2022 by zhu-mingye Committed by GitHub Jul 19, 2022
Show whitespace changes
Inline Side-by-side

Showing with 4 additions and 1 deletion

Submiter.java ...p-base/src/main/java/com/dlink/app/flinksql/Submiter.java +4 -1

No files found.
--- a/dlink-app/dlink-app-base/src/main/java/com/dlink/app/flinksql/Submiter.java
+++ b/dlink-app/dlink-app-base/src/main/java/com/dlink/app/flinksql/Submiter.java
@@ -99,7 +99,10 @@ public class Submiter {
        StringBuilder sb = new StringBuilder();
        Map<String, String> taskConfig = Submiter.getTaskConfig(id, dbConfig);
        if (Asserts.isNotNull(taskConfig.get("envId"))) {
-            sb.append(getFlinkSQLStatement(Integer.valueOf(taskConfig.get("envId")), dbConfig));
+            String envId = getFlinkSQLStatement(Integer.valueOf(taskConfig.get("envId")), dbConfig);
+            if (Asserts.isNotNullString(envId)) {
+                sb.append(envId);
+            }
            sb.append("\r\n");
        }
        sb.append(getFlinkSQLStatement(id, dbConfig));