You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/05/26 18:49:00 UTC
[jira] [Created] (FLINK-12628) Check test failure if partition has
no consumers in Execution.getPartitionMaxParallelism
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)