[
https://issues.apache.org/jira/browse/FLINK-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-10790.
----------------------------
Resolution: Won't Fix
It is not very necessary/feasible to do this now. Close it now and if necessary
we could reopen future.
> Refactor all the StreamPartitioner implementations into runtime module
> ----------------------------------------------------------------------
>
> Key: FLINK-10790
> URL: https://issues.apache.org/jira/browse/FLINK-10790
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Network
> Affects Versions: 1.8.0
> Reporter: zhijiang
> Assignee: zhijiang
> Priority: Minor
> Labels: pull-request-available
> Time Spent: 10m
> Remaining Estimate: 0h
>
> The motivation is for refactoring {{ChannelSelector}} interface mentioned in
> [FLINK-10662|https://issues.apache.org/jira/browse/FLINK-10662].
> The {{ChannelSelector}} implementations are separate for stream and batch
> currently, resulting in many duplicated logics for selecting channels. The
> root cause is that they are locating in different modules to not reuse the
> existing ones.
> In general, the core runtime codes should be unified for both stream and
> batch jobs as much as possible, then we can reduce the work overhead to
> maintain the duplicated codes.
> This jira would migrate the existing partitioner package from
> {{flink-streaming-jave}} to {{flink-runtime}}. Next we want to de-duplicate
> implementations for {{RoundRobinChannelSelector}} and {{OutputEmitter}}.
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
