From 86d205f8958342beb22e97e09ee616b6a5dc755d Mon Sep 17 00:00:00 2001
From: gaoyan <ikiler@126.com>
Date: Fri, 2 Feb 2024 16:20:52 +0800
Subject: [PATCH] [Fix]Fix app mode Global Varible Exception (#3134)

Co-authored-by: gaoyan1998 <gaoyan1998@users.noreply.github.com>
---
 .../src/main/java/org/dinky/app/flinksql/Submitter.java          | 1 +
 1 file changed, 1 insertion(+)

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())