[flink] branch release-1.12 updated: [FLINK-20078][hotfix][coordination] Use executionGraph.getTotalNumberOfVertices in DefaultExecutionTopology

[azagrebin]

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

azagrebin pushed a commit to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.12 by this push:
     new f676e4d  [FLINK-20078][hotfix][coordination] Use 
executionGraph.getTotalNumberOfVertices in DefaultExecutionTopology
f676e4d is described below

commit f676e4df7253d4fd511eb659edcff98e0013bbbd
Author: azagrebin <azagre...@gmail.com>
AuthorDate: Mon Nov 16 10:25:42 2020 +0300

    [FLINK-20078][hotfix][coordination] Use 
executionGraph.getTotalNumberOfVertices in DefaultExecutionTopology
    
    Co-authored-by: Zhu Zhu <reed...@gmail.com>
    
    This closes #14020.
---
 .../flink/runtime/scheduler/adapter/DefaultExecutionTopology.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java
index 178b4fd..ce085d3 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java
@@ -120,7 +120,7 @@ public class DefaultExecutionTopology implements 
SchedulingTopology {
 
                ExecutionGraphIndex executionGraphIndex = 
computeExecutionGraphIndex(
                        executionGraph.getAllExecutionVertices(),
-                       executionGraph.getNumberOfExecutionJobVertices());
+                       executionGraph.getTotalNumberOfVertices());
 
                IndexedPipelinedRegions indexedPipelinedRegions =
                        
computePipelinedRegions(executionGraphIndex.executionVerticesList);