Weijie Guo created FLINK-29034: ---------------------------------- Summary: HYBRID_FULL result partition type is not yet reConsumable Key: FLINK-29034 URL: https://issues.apache.org/jira/browse/FLINK-29034 Project: Flink Issue Type: Bug Components: Runtime / Coordination Affects Versions: 1.16.0 Reporter: Weijie Guo Fix For: 1.16.0
HYBRID_FULL partitions can be consumed repeatedly, but it does not support concurrent consumption. So re-consumable is false, but double calculation can be avoided during failover. If we regard it as re-consumable, there will be problems when the partition is reused. Therefore, we temporarily set this field false, and reset it to true when HsResultPartition supports downstream concurrent consumption of multiple identical subpartitions. -- This message was sent by Atlassian Jira (v8.20.10#820010)