[jira] [Comment Edited] (FLINK-39210) Memory Leak Issue in Flink SQL with Multiple Temporal Joins

["Qilong Wang (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-39210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18075325#comment-18075325 ] 

Qilong Wang edited comment on FLINK-39210 at 4/22/26 4:03 AM:
--------------------------------------------------------------

I am trying to fix this issue in [[F|https://github.com/apache/flink/pull/27992]LINK-39210|https://github.com/apache/flink/pull/27992]


was (Author: JIRAUSER306284):
I am trying to fix this issue in [F|https://github.com/apache/flink/pull/27992]LINK-39210

> Memory Leak Issue in Flink SQL with Multiple Temporal Joins
> -----------------------------------------------------------
>
>                 Key: FLINK-39210
>                 URL: https://issues.apache.org/jira/browse/FLINK-39210
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / Runtime
>    Affects Versions: 1.20.3, 2.2.0, 2.1.1
>            Reporter: Fred Teunissen
>            Priority: Major
>              Labels: pull-request-available
>
> There is a memory issue in Flink SQL when using multiple temporal joins in a single query.
> {code:sql}
> INSERT INTO blackhole_table
> SELECT
>     orders.customer_id,
>     order_id,
>     price,
>     orders.currency,
>     conversion_rate,
>     order_time
> FROM orders
>     LEFT JOIN config FOR SYSTEM_TIME AS OF orders.order_time
>         ON orders.customer_id = config.customer_id
>     INNER JOIN currency_rates FOR SYSTEM_TIME AS OF orders.order_time
>         ON orders.currency = currency_rates.currency;{code}
> To reproduce this in docker see [repository on github|https://github.com/FredTing/memory-leak-temporal-join]



--
This message was sent by Atlassian Jira
(v8.20.10#820010)