[
https://issues.apache.org/jira/browse/FLINK-19165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-19165.
------------------------------------
Resolution: Fixed
Implemented in e2deb9227387a7fbbf090c8279698194e2611f75
> Clean up the UnilateralSortMerger
> ---------------------------------
>
> Key: FLINK-19165
> URL: https://issues.apache.org/jira/browse/FLINK-19165
> Project: Flink
> Issue Type: Sub-task
> Components: API / Core
> Reporter: Dawid Wysakowicz
> Assignee: Dawid Wysakowicz
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.12.0
>
>
> This is a preparation step for
> [FLIP-140|https://cwiki.apache.org/confluence/display/FLINK/FLIP-140%3A+Introduce+bounded+style+execution+for+keyed+streams].
> The purpose of the task is two-folds:
> * break down the implementation into a more composable pieces
> * introduce a way to produce records in a push-based manner instead of
> pull-based with additional reading thread.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
