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

["Fred Teunissen (Jira)" <ji...@apache.org>]

Fred Teunissen created FLINK-39210:
--------------------------------------

             Summary: 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: 2.1.1, 2.2.0, 1.20.3
            Reporter: Fred Teunissen


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)