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
index b1243259cc..8d7e5187e0 100644
--- 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())