This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch args
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/args by this push:
new 9d48f1ca0 minor improvement
9d48f1ca0 is described below
commit 9d48f1ca0da24baaed89e41aceac30d328bf64de
Author: benjobs <[email protected]>
AuthorDate: Sun Oct 29 00:51:27 2023 +0800
minor improvement
---
.../org/apache/streampark/flink/client/trait/FlinkClientTrait.scala | 1 +
1 file changed, 1 insertion(+)
diff --git
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
index 271d3d0df..aa21ea3ce 100644
---
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
+++
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
@@ -271,6 +271,7 @@ trait FlinkClientTrait extends Logger {
// python.executable
.safeSet(PythonOptions.PYTHON_EXECUTABLE, Constant.PYTHON_EXECUTABLE)
case _ =>
+ pkgBuilder.setJarFile(submitRequest.userJarFile)
}
val packageProgram = pkgBuilder.build()
