Github user tillrohrmann commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5478#discussion_r168171127
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
 ---
    @@ -698,7 +707,7 @@ else if (numConsumers == 0) {
                                        executor);
     
                                // double check to resolve race conditions
    -                           if(consumerVertex.getExecutionState() == 
RUNNING){
    +                           if (consumerVertex.getExecutionState() == 
RUNNING){
                                        consumerVertex.sendPartitionInfos();
    --- End diff --
    
    Good catch @zhangminglei. Will fix it.


---

Reply via email to