Re: Pyflink JVM Metaspace 内存泄漏定位

Wed, 20 Jan 2021 03:19:52 -0800 

我是Python的table
API实现的，connector是jdbc，jar包是用的flink网站上提供的链接里的（https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/connectors/jdbc.html），有
flink-connector-jdbc_2.11-1.12.0.jar 和 mysql-connector-java-5.1.49.jar。

任务是用SQL写的，基本和flink提供的demo的代码一致：
"
) WITH (
   'connector' = 'jdbc',
   'url' = 'jdbc:mysql://localhost:3306/mydatabase',
   'table-name' = 'users'
);
"

Jmap导出的数据分析看如下：
<http://apache-flink.147419.n8.nabble.com/file/t1276/WX20210120-191436.png> 




--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复