[FLINK-32110] TM native memory leak when using time window in Pyflink ThreadMode

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.17.0
• Fix Version/s: 1.17.2
• Component/s: API / Python
• Assignee: Yunjun Luo
• Reporter: Yunjun Luo
• Created: 16/May/23 14:06
• Updated: 25/May/23 09:50
• Resolved: 25/May/23 09:50

Description

If job use time window in Pyflink thread mode, TM native memory will grow slowly during the job running until TM can't allocate memory from operate system.

The leak rate is likely proportional to the number of key.