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)
