This is an automated email from the ASF dual-hosted git repository. benjobs pushed a commit to branch CANCEL_ENABLE in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
commit d9b9503c68349803cfcb013ec6e244b013f76f05 Author: benjobs <[email protected]> AuthorDate: Sat May 13 21:54:52 2023 +0800 [Bug] flink CANCEL_ENABLE bug fixed. --- .../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())
