flink-connector-jdbc
flink-connector-jdbc copied to clipboard
[FLINK-30960] Fix a corner case oom error
I fixed a corner case out-of-memory error when we use a timed flushing interval, where the scheduler thread could repeatly throw a new RuntimeException wrapping the previous one as cause. This could lead to an infinite object reference chain.