Andrey Zagrebin created FLINK-12628:
---------------------------------------
Summary: Check test failure if partition has no consumers in
Execution.getPartitionMaxParallelism
Key: FLINK-12628
URL: https://issues.apache.org/jira/browse/FLINK-12628
Project: Flink
Issue Type: Improvement
Components: Runtime / Coordination
Reporter: Andrey Zagrebin
Currently, we work around this case in Execution.getPartitionMaxParallelism
because of tests:
// TODO consumers.isEmpty() only exists for test, currently there has to be
exactly one consumer in real jobs!
though partition is supposed to have always at least one consumer atm.
We should check which test fails and consider fixing it.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
