Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.12.2
Description
In our company cases, short-life-cycle & huge RowData will use this operator to join each other. Every key called session_id will be expired after 2min.
With idle.state.retention.time configuration, after 2min if not used, the leftState and rightState will be cleaned up by the operator but nextLeftIndex & registeredTimer state data will be stored forever.
After running a day(about 20 million session_id in our company cases), the checkpoint operator will cause the job crash.
I have found the bug, and fixed it.
Attachments
Attachments
Issue Links
- Blocked
-
FLINK-25695 TemporalJoin cause state leak in some cases
- Open
- links to