[
https://issues.apache.org/jira/browse/FLINK-19822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-19822:
-------------------------------
Description:
This is similar
[FLINK-12575|https://issues.apache.org/jira/browse/FLINK-12575], we could
implement {{satisfyTraits}} method for stream nodes to remove redundant
shuffle. This could add more possibilities that more operators can be merged
into multiple input operator.
Note: This feature should only be enabled only when multiple input operator is
enabled because currently key selector is applied only at the header of the
chain, the state access of other operators in the chain may be not correct.
was:
This is similar
[FLINK-12575|https://issues.apache.org/jira/browse/FLINK-12575], we could
implement {{satisfyTraits}} method for stream nodes to remove redundant
shuffle. This could add more possibilities that more operators can be merged
into multiple input operator.
Note: This feature should only be enabled only when multiple input operator is
enabled because currently key selector is applied only at the header of the
chain.
> Remove redundant shuffle for stream
> -----------------------------------
>
> Key: FLINK-19822
> URL: https://issues.apache.org/jira/browse/FLINK-19822
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Planner
> Reporter: godfrey he
> Assignee: godfrey he
> Priority: Major
> Fix For: 1.12.0
>
>
> This is similar
> [FLINK-12575|https://issues.apache.org/jira/browse/FLINK-12575], we could
> implement {{satisfyTraits}} method for stream nodes to remove redundant
> shuffle. This could add more possibilities that more operators can be merged
> into multiple input operator.
> Note: This feature should only be enabled only when multiple input operator
> is enabled because currently key selector is applied only at the header of
> the chain, the state access of other operators in the chain may be not
> correct.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
