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 <[email protected]>
AuthorDate: Wed Sep 6 20:22:22 2023 +0800
[issues-3027][fix]remove redundant tasks submit logic (#3028)
Co-authored-by: alex.wang <[email protected]>
---
.../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
