[flink] branch FLINK-14651 updated: Remove wrong checkState

[gary]

This is an automated email from the ASF dual-hosted git repository.

gary pushed a commit to branch FLINK-14651
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/FLINK-14651 by this push:
     new 9e9c950  Remove wrong checkState
9e9c950 is described below

commit 9e9c95008d2e0baa8f930f0b4a9c1cde709cdf27
Author: Gary Yao <g...@apache.org>
AuthorDate: Mon Nov 25 17:41:46 2019 +0100

    Remove wrong checkState
---
 .../java/org/apache/flink/runtime/scheduler/DefaultScheduler.java   | 6 ------
 1 file changed, 6 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
index 407f13b..e557818 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
@@ -438,12 +438,6 @@ public class DefaultScheduler extends SchedulerBase 
implements SchedulerOperatio
 
                return (ignored, throwable) -> {
                        if 
(executionVertexVersioner.isModified(requiredVertexVersion)) {
-                               final boolean slotAlive = deploymentHandle
-                                       .getLogicalSlot()
-                                       .map(LogicalSlot::isAlive)
-                                       .orElse(false);
-                               checkState(!slotAlive, "Expected slot to be 
released");
-
                                log.debug("Refusing to deploy execution vertex 
{} because this deployment was " +
                                        "superseded by another deployment", 
executionVertexId);
                                return null;