Jiayi-Liao commented on pull request #15016: URL: https://github.com/apache/flink/pull/15016#issuecomment-803950932
> To make a review here, I would need a bit more context about this problem. @Jiayi-Liao if you can give me a bit of context for you assumptions on this fix, I can do a review here. There is a memory leak issue in the incremental cleanup of #TtlMapState and #TtlListState in FsStateBackend. The #TtlIncrementalCleanup expires the state from #StateTable when #getUnexpiredOrNull(ttlValue) returns null, but #TtlMapState and #TtlListState never return null in the method, which means the #TtlMapState and #TtlListState will never be removed from #StateTable. We met the issue when we're trying to process a stream of new devices and the range of new devices is unbounded. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
