apache / incubator-streampark

Make stream processing easier! Easy-to-use streaming application development framework and operation platform.
https://streampark.apache.org/
Apache License 2.0
3.89k stars 1.01k forks source link

[Bug] There is memory leak inside CheckpointProcessor #1569

Closed 1996fanrui closed 2 years ago

1996fanrui commented 2 years ago

Search before asking

What happened

The checkPointCache inside CheckpointProcessor is just put and get, all data are not removed anywhere.

StreamPark Version

the latest dev branch

Java Version

No response

Flink Version

*

Scala Version of Flink

*

Error Exception

*

Screenshots

No response

Are you willing to submit PR?

Code of Conduct

wolfboys commented 2 years ago

thanks for your suggestion, welcome to improve this issue.

1996fanrui commented 2 years ago

Yeah, I am working on this.