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)