Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6103#discussion_r191753857
--- 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 --
This change will break deployments where `allowLazyDeployment` is set to
`false`. In the Flip-6 code, this is per default set to `true`, but for the
legacy mode, the value is `false`. Thus, we would have to first remove the
legacy mode and `allowLazyDeployment`.
---
