Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6103#discussion_r192558687
--- 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 --
Yes, I would say that we tackle this problem after we have removed the
legacy code. For the moment, there is a work around to set the max backoff time
higher for the data connections.
---
