Merge branch 'DataLinkDC:dev' into dev

gaoyan1998 · Feb 2, 2024 · 11957fb · 11957fb
2 parents 039c961 + 86d205f
commit 11957fb
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())