[flink] branch master updated: [hotfix][runtime] Fix result partition redundantly added in TestingSchedulingTopology

[trohrmann]

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

trohrmann 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 364c6b3  [hotfix][runtime] Fix result partition redundantly added in 
TestingSchedulingTopology
364c6b3 is described below

commit 364c6b33706bca8d04da28b4fb2f3cad7add226e
Author: Bo WANG <wbeaglewatc...@gmail.com>
AuthorDate: Thu Jun 13 16:46:43 2019 +0800

    [hotfix][runtime] Fix result partition redundantly added in 
TestingSchedulingTopology
    
    This closes #8725.
---
 .../flink/runtime/scheduler/strategy/TestingSchedulingTopology.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/TestingSchedulingTopology.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/TestingSchedulingTopology.java
index 2a84ba3..1aaac58 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/TestingSchedulingTopology.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/TestingSchedulingTopology.java
@@ -210,8 +210,8 @@ public class TestingSchedulingTopology implements 
SchedulingTopology {
                                for (TestingSchedulingExecutionVertex consumer 
: consumers) {
                                        
consumer.addConsumedPartition(resultPartition);
                                        resultPartition.addConsumer(consumer);
-                                       resultPartitions.add(resultPartition);
                                }
+                               resultPartitions.add(resultPartition);
                        }
 
                        return resultPartitions;