You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Lyn Zhang (Jira)" <ji...@apache.org> on 2022/01/19 02:55:00 UTC
[jira] [Created] (FLINK-25695) TemporalJoin cause state leak in some case
Lyn Zhang created FLINK-25695:
---------------------------------
Summary: TemporalJoin cause state leak in some case
Key: FLINK-25695
URL: https://issues.apache.org/jira/browse/FLINK-25695
Project: Flink
Issue Type: Bug
Components: Table SQL / Runtime
Affects Versions: 1.14.3
Reporter: Lyn Zhang
Last year, I report the similar bug of TemporalJoin cause state leak.
Detail: [https://github.com/apache/flink/pull/14916]
Recently, I found the fix code can reduce the the leak size but can not resolve it completely.
The code of line 213 cause that and The right fix is to invoke cleanUp() method.
The [https://github.com/apache/flink/pull/14916] We discussed that if the code is running on line 213, That meaning Left State, Right State, registeredTimerState is empty, actually the Left State and Right State value(MapState) is empty but the key is still be in state, So invoke state.clear() is necessary.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)