Hi Team,

My streaming pipeline is based on beam & running using flink runner with 
rocksdb as state backend.

Over time I am  seeing memory spike & after giving a look at heap dump, I am 
seeing records in  ‘__StatefulParDoGcTimerId’ which seems to be never cleaned.

Found this jira https://issues.apache.org/jira/browse/BEAM-8212 describing the 
issue I believe I am facing.

Any pointers would be helpful in identifying possible solution.

Thanks,
Julius

Reply via email to