[FLINK-18533][coordination] Disable cancellation of unknown deployments

Temporarily disabled due to stability issues.
spotify · Jul 9, 2020 · 6e811e6 · 6e811e6
1 parent 03934b3
commit 6e811e6
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
@@ -254,7 +254,7 @@ public void onUnknownDeploymentsOf(Collection<ExecutionAttemptID> executionAttem
  for (ExecutionAttemptID executionAttemptId : executionAttemptIds) {
  Tuple2<TaskManagerLocation, TaskExecutorGateway> taskManagerInfo = registeredTaskManagers.get(host);
  if (taskManagerInfo != null) {
- taskManagerInfo.f1.cancelTask(executionAttemptId, rpcTimeout);
+ //taskManagerInfo.f1.cancelTask(executionAttemptId, rpcTimeout);
  }
  }
  }

diff --git a/...va/org/apache/flink/runtime/jobmaster/JobMasterExecutionDeploymentReconciliationTest.java b/...va/org/apache/flink/runtime/jobmaster/JobMasterExecutionDeploymentReconciliationTest.java
@@ -48,6 +48,7 @@
 
 import org.junit.Before;
 import org.junit.ClassRule;
+import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
 
@@ -88,6 +89,7 @@ public void setup() {
  }
 
  @Test
+ @Ignore
  public void testExecutionDeploymentReconciliation() throws Exception {
  JobMasterBuilder.TestingOnCompletionActions onCompletionActions = new JobMasterBuilder.TestingOnCompletionActions();