[flink] branch master updated: [FLINK-22345][coordination] Remove incorrect assertion in scheduler

[sewen]

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

sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 02e7db8  [FLINK-22345][coordination] Remove incorrect assertion in 
scheduler
02e7db8 is described below

commit 02e7db875920b34099cfb570089da20da6a88cb1
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Wed Apr 21 23:21:33 2021 +0200

    [FLINK-22345][coordination] Remove incorrect assertion in scheduler
    
    When this incorrect assertion is violated, the scheduler can trip into an 
unrecoverable
    failover loop.
---
 .../main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java    | 3 ---
 1 file changed, 3 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java
index c675e66..b8ab9a2 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java
@@ -396,9 +396,6 @@ public abstract class SchedulerBase implements SchedulerNG, 
CheckpointScheduling
             final Set<ExecutionJobVertex> jobVerticesToRestore =
                     getInvolvedExecutionJobVertices(vertices);
 
-            // a global restore restores all Job Vertices
-            assert jobVerticesToRestore.size() == 
getExecutionGraph().getAllVertices().size();
-
             
checkpointCoordinator.restoreLatestCheckpointedStateToAll(jobVerticesToRestore, 
true);
 
         } else {