wangkang created FLINK-30512:
--------------------------------
Summary: Flink SQL state TTL has no effect when using Interval Join
Key: FLINK-30512
URL: https://issues.apache.org/jira/browse/FLINK-30512
Project: Flink
Issue Type: Bug
Components: Runtime / State Backends
Affects Versions: 1.15.1, 1.16.1
Reporter: wangkang
Attachments: flink1.16.png
Take the following join SQL program as an example:
{code:java}
SET 'table.exec.state.ttl' = '900000 ms';
select
...
from kafka_source_dwdexpose as t1
left join kafka_source_expose_attr_click t3
ON t1.mid = t3.mid and t1.sr = t3.sr
and t1.time_local = t3.time_local
and t1.log_ltz BETWEEN t3.log_ltz - INTERVAL '2' MINUTE AND t3.log_ltz +
INTERVAL '2' MINUTE {code}
!flink1.16.png!
the state size is getting bigger and bigger.
we also test the same sql with flink sql 1.13,the state size is stable.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
