Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6103#discussion_r191814673
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/deployment/InputChannelDeploymentDescriptor.java
---
@@ -103,9 +103,7 @@ public String toString() {
// The producing task needs to be RUNNING or already
FINISHED
if (consumedPartition.isConsumable() && producerSlot !=
null &&
(producerState ==
ExecutionState.RUNNING ||
- producerState ==
ExecutionState.FINISHED ||
- producerState ==
ExecutionState.SCHEDULED ||
- producerState ==
ExecutionState.DEPLOYING)) {
--- End diff --
Thank you till. But where is legacy code ? I found a lot of code belongs to
legacy mode.........omg....I do not think I should remove all legacy mode
code....... Could you tell me please ? Lol.
---
