[flink] branch release-1.13 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 release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git


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

commit 41f013db8605ce47cbc9b1e7b69c3cb0359873ef
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 {