You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2019/11/27 17:46:02 UTC
[flink] 01/01: Remove wrong checkState
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
commit 0d1c43842ddbe66040b70aaca151a7a7b945dc91
Author: Gary Yao <ga...@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;