[
https://issues.apache.org/jira/browse/FLINK-19046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-19046.
----------------------------------
Resolution: Fixed
Fixed in 1.12 via 91d380788005d35fcb14a2fe66ae6ca9e72e529d
> Introduce separate classes for PipelinedResultPartition and
> BoundedBlockingResultPartition
> ------------------------------------------------------------------------------------------
>
> Key: FLINK-19046
> URL: https://issues.apache.org/jira/browse/FLINK-19046
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Network
> Reporter: Stephan Ewen
> Assignee: Stephan Ewen
> Priority: Major
> Fix For: 1.12.0
>
>
> Currently, the SubPartition classes are specific to the partition type
> (pipelined, batched/blocking) but the parent Partition class is shared.
> Given that the partitions behave differently regarding checkpoints,
> releasing, etc. the code is cleaner separated by introducing dedicated
> classes for the {{ResultPartitions}} based on the type.
> This is also an important preparation to later have more different
> implementations, like sort-based shuffles.
> Important: These new classes will not override any performance critical
> methods (like adding a buffer to the result). They merely specialize certain
> behaviors around checkpointing and cleanup.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
