Checkpoint is disable, will history data in rocksdb be leak when job restart?
Posted by SmileSmile on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Checkpoint-is-disable-will-history-data-in-rocksdb-be-leak-when-job-restart-tp36340.html
Hi
My job work on flink 1.10.1 with event time , container memory usage will rise 2G after one restart，then pod will be killed by os after some times restart。
I find history data will be cleared when new data arrive, call the function onEventTime() to clearAllState.But my job no need Checkpoint , when job restart, will the history data leaf in the offheap momory and never be clear?
This case only happend when I use rocksdb，Heap backend is ok。
Can anyone help me on how to deal with this?
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Checkpoint-is-disable-will-history-data-in-rocksdb-be-leak-when-job-restart-tp36340.html
Hi
My job work on flink 1.10.1 with event time , container memory usage will rise 2G after one restart，then pod will be killed by os after some times restart。
I find history data will be cleared when new data arrive, call the function onEventTime() to clearAllState.But my job no need Checkpoint , when job restart, will the history data leaf in the offheap momory and never be clear?
This case only happend when I use rocksdb，Heap backend is ok。
Can anyone help me on how to deal with this?
| Free forum by Nabble | Edit this page |