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.
---