fix_flink_jar_sql

DataLinkDC · Dec 23, 2024 · 87a08bf · 87a08bf
1 parent de3aeed
commit 87a08bf
Showing 1 changed file with 1 addition 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,7 @@ public JobStatementPlan parseStatementIntoJobStatementPlan(String[] statements)
             } else if (operationType.equals(SqlType.EXECUTE_JAR)) {
                 JarSubmitParam jarSubmitParam = JarSubmitParam.build(statement);
                 String args = jarSubmitParam.getArgs();
-                jarSubmitParam.setUri("base64@" + Base64.encode(isUseSqlFragment() ? pretreatStatement(args) : args));
+                jarSubmitParam.setArgs("base64@" + Base64.encode(isUseSqlFragment() ? pretreatStatement(args) : args));
                 jobStatementPlan.addJobStatement(
                         jarSubmitParam.getStatement(), JobStatementType.EXECUTE_JAR, operationType);
             } else if (operationType.equals(SqlType.EXECUTE)) {