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
