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)

Reply via email to