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)

Reply via email to