[
https://issues.apache.org/jira/browse/FLINK-37403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bonnie Varghese updated FLINK-37403:
------------------------------------
Description:
This can be done by converting the IntervalJoin node to RegularJoin node if the
input to IntervalJoin contains updates.
Currently, the system converts IntervalJoin to RegularJoin during the
LogicalPlan phase if the join conditions contains a timestamp field which is
not a time attribute field.
> Support retractions/updates for IntervalJoin operator
> -----------------------------------------------------
>
> Key: FLINK-37403
> URL: https://issues.apache.org/jira/browse/FLINK-37403
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / Planner
> Reporter: Bonnie Varghese
> Assignee: Bonnie Varghese
> Priority: Major
> Fix For: 2.0.0
>
>
> This can be done by converting the IntervalJoin node to RegularJoin node if
> the input to IntervalJoin contains updates.
> Currently, the system converts IntervalJoin to RegularJoin during the
> LogicalPlan phase if the join conditions contains a timestamp field which is
> not a time attribute field.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
