michaelxiang created FLINK-28205: ------------------------------------ Summary: jdbc connector 定时调度 flush 存在内存泄漏 bug Key: FLINK-28205 URL: https://issues.apache.org/jira/browse/FLINK-28205 Project: Flink Issue Type: Bug Components: Connectors / JDBC Affects Versions: 1.14.5, 1.13.6, 1.15.0 Reporter: michaelxiang
类路径:org.apache.flink.connector.jdbc.internal.JdbcBatchingOutputFormat bug位置:open方法,调度线程Runnable 实例 采用flink-connector-jdbc 进行写入时, 定时调度线程进行 flush 出现异常情况时对 RuntimeException 进行了捕获,这会导致在新数据到达 Task 前不会发生故障退出,因而定时调度线程则会不停的通过创建RuntimeException 进行包裹 上一个创建的 flushException,对于flushException 无法释放引用被GC回收,从而导致内存泄漏。 -- This message was sent by Atlassian Jira (v8.20.7#820007)