You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2023/10/28 16:51:41 UTC

(incubator-streampark) branch args updated: minor improvement

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 <be...@gmail.com>
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()