[jira] [Created] (FLINK-12628) Check test failure if partition has no consumers in Execution.getPartitionMaxParallelism

[Shang Yuanchun (Jira)]

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)