[Bugfix][FlinkJar]Fix FlinkJar args global variable parsing (#4113)

Co-authored-by: zackyoungh <[email protected]>
DataLinkDC · Jan 3, 2025 · 779d803 · 779d803
1 parent 91af61a
commit 779d803
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/dinky-core/src/main/java/org/dinky/executor/Executor.java b/dinky-core/src/main/java/org/dinky/executor/Executor.java
@@ -218,7 +218,9 @@ public JobStatementPlan parseStatementIntoJobStatementPlan(String[] statements)
             } else if (operationType.equals(SqlType.EXECUTE_JAR)) {
                 JarSubmitParam jarSubmitParam = JarSubmitParam.build(statement);
                 String args = jarSubmitParam.getArgs();
-                jarSubmitParam.setArgs("base64@" + Base64.encode(isUseSqlFragment() ? pretreatStatement(args) : args));
+                jarSubmitParam.setArgs("base64@"
+                        + Base64.encode(
+                                isUseSqlFragment() ? getVariableManager().parseVariable(args) : args));
                 jobStatementPlan.addJobStatement(
                         jarSubmitParam.getStatement(), JobStatementType.EXECUTE_JAR, operationType);
             } else if (operationType.equals(SqlType.EXECUTE)) {