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/09/06 12:22:28 UTC
[incubator-streampark] branch dev-2.1.2 updated: [issues-3027][fix]remove redundant tasks submit logic (#3028)
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 f7cd4b3da [issues-3027][fix]remove redundant tasks submit logic (#3028)
f7cd4b3da is described below
commit f7cd4b3da591c84c6c75c40abf37a8208c31b423
Author: alex justin <12...@users.noreply.github.com>
AuthorDate: Wed Sep 6 20:22:22 2023 +0800
[issues-3027][fix]remove redundant tasks submit logic (#3028)
Co-authored-by: alex.wang <al...@linktime.cloud>
---
.../org/apache/streampark/flink/client/trait/FlinkClientTrait.scala | 5 -----
1 file changed, 5 deletions(-)
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 43308ae86..aa91aed32 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
@@ -147,11 +147,6 @@ trait FlinkClientTrait extends Logger {
}
})
}
-
- setConfig(submitRequest, flinkConfig)
-
- doSubmit(submitRequest, flinkConfig)
-
}
def setConfig(submitRequest: SubmitRequest, flinkConf: Configuration): Unit