This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev-2.1.2
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev-2.1.2 by this push:
new e7409f037 flink job batchMode bug fixed.
e7409f037 is described below
commit e7409f037adfe16eb3a8981a53104e9145e6cc35
Author: benjobs <[email protected]>
AuthorDate: Sat Aug 26 17:08:08 2023 +0800
flink job batchMode bug fixed.
---
.../org/apache/streampark/flink/client/trait/FlinkClientTrait.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 074d9fad5..8331517c8 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
@@ -479,7 +479,7 @@ trait FlinkClientTrait extends Logger {
if (submitRequest.properties.nonEmpty) {
if
(submitRequest.properties.containsKey(ExecutionOptions.RUNTIME_MODE.key())) {
programArgs += s"--${ExecutionOptions.RUNTIME_MODE.key()}"
- programArgs +=
submitRequest.properties.get(ExecutionOptions.RUNTIME_MODE.key())
+ programArgs +=
submitRequest.properties.get(ExecutionOptions.RUNTIME_MODE.key()).toString
}
}
programArgs.toList.asJava
