[Bug]fix flink cdc task lost sql in app mode (DataLinkDC#3439)

Co-authored-by: gaoyan1998 <[email protected]>
Zzm0809 · Apr 29, 2024 · 280ef09 · 280ef09
1 parent cbce5fd
commit 280ef09
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/dinky-core/src/main/java/org/dinky/job/builder/JobExecuteBuilder.java b/dinky-core/src/main/java/org/dinky/job/builder/JobExecuteBuilder.java
@@ -65,6 +65,8 @@ public void run() throws Exception {
                 }
                 GatewayResult gatewayResult = null;
                 config.addGatewayConfig(executor.getSetConfig());
+                config.getGatewayConfig().setSql(jobParam.getParsedSql());
+
                 if (runMode.isApplicationMode()) {
                     gatewayResult = Gateway.build(config.getGatewayConfig())
                             .submitJar(executor.getDinkyClassLoader().getUdfPathContextHolder());