[
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: to ensure the key range is correct, the shuffle can be removed only if
the required keys must totally equal to the provided keys
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, the state access of other operators in the chain may be not correct.
> Remove redundant shuffle for streaming
> --------------------------------------
>
> 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: to ensure the key range is correct, the shuffle can be removed only if
> the required keys must totally equal to the provided keys
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
