[Fix]Fix app mode Global Varible Exception (DataLinkDC#3134)

Co-authored-by: gaoyan1998 <[email protected]>
gaoyan1998 · Feb 2, 2024 · 86d205f · 86d205f
1 parent d435984
commit 86d205f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/dinky-app/dinky-app-base/src/main/java/org/dinky/app/flinksql/Submitter.java b/dinky-app/dinky-app-base/src/main/java/org/dinky/app/flinksql/Submitter.java
@@ -111,6 +111,7 @@ public static void submit(AppParamConfig config) throws SQLException {
                 .type(appTask.getType())
                 .checkpoint(appTask.getCheckPoint())
                 .parallelism(appTask.getParallelism())
+                .useSqlFragment(appTask.getFragment())
                 .useStatementSet(appTask.getStatementSet())
                 .useBatchModel(appTask.getBatchModel())
                 .savePointPath(appTask.getSavePointPath())