You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by mu...@apache.org on 2023/05/13 13:58:38 UTC
[incubator-streampark] branch dev updated: [Bug] flink CANCEL_ENABLE bug fixed. (#2748)
This is an automated email from the ASF dual-hosted git repository.
muchunjin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev by this push:
new 9793e7106 [Bug] flink CANCEL_ENABLE bug fixed. (#2748)
9793e7106 is described below
commit 9793e71064b1564ad20c17bbee6aab2c951df0f6
Author: benjobs <be...@apache.org>
AuthorDate: Sat May 13 21:58:33 2023 +0800
[Bug] flink CANCEL_ENABLE bug fixed. (#2748)
---
.../org/apache/streampark/flink/client/trait/FlinkClientTrait.scala | 2 --
1 file changed, 2 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 dca2863cc..325bc9ff3 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
@@ -40,7 +40,6 @@ import org.apache.flink.util.FlinkException
import org.apache.flink.util.Preconditions.checkNotNull
import java.io.File
-import java.lang.{Boolean => JavaBool}
import java.util.{Collections, List => JavaList, Map => JavaMap}
import scala.annotation.tailrec
@@ -99,7 +98,6 @@ trait FlinkClientTrait extends Logger {
.safeSet(ApplicationConfiguration.APPLICATION_MAIN_CLASS, submitRequest.appMain)
.safeSet(ApplicationConfiguration.APPLICATION_ARGS, extractProgramArgs(submitRequest))
.safeSet(PipelineOptionsInternal.PIPELINE_FIXED_JOB_ID, submitRequest.jobId)
- .safeSet(WebOptions.CANCEL_ENABLE, JavaBool.FALSE)
if (
!submitRequest.properties.containsKey(CheckpointingOptions.MAX_RETAINED_CHECKPOINTS.key())