[
https://issues.apache.org/jira/browse/FLINK-22714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-22714.
------------------------------
Resolution: Fixed
Fixed in 1.14.0: f61d9af916092568a0bd76a23cd2a17ec9cc6bb0
> Simplify `StreamPhysicalWindowTableFunction` to a simple window assigner if
> successor node with `WindowAttachedWindowingStrategy` in planner
> ---------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-22714
> URL: https://issues.apache.org/jira/browse/FLINK-22714
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Planner
> Affects Versions: 1.14.0
> Reporter: JING ZHANG
> Assignee: JING ZHANG
> Priority: Major
> Labels: pull-request-available, stale-assigned
>
> In theory, `StreamPhysicalWindowTableFunction` should works as a window
> assigner and emits at ends of window. However,
> `StreamPhysicalWindowTableFunction` could be simplified to a simple window
> assigner, and emits per record if it's successor node is one of
> `WindowRank`/`WindowJoin`/`WindowAggregate` with
> `WindowAttachedWindowingStrategy`, because those nodes would assign input
> records to windows have been assigned in input nodes, and trigger emit at
> ends of window.
> Besides, we should add a limit that window is based on rowtime, because it
> has syntax problem if window is assigned based on the proc-time of previous
> operator.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
