Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5478#discussion_r168166947
--- 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 --
It seems missing a space after ```if``` statement.
---