非常感谢回复！ Flink 版本是使用的 1.12.0，通过 https://github.com/apache/flink-docker/tree/master/1.12/scala_2.12-java11-debian 编译的Docker 镜像，然后外层又安装的python3环境生成最终的镜像。（不知道为什么我发的邮件到平台上后会少一部分，我又单独在平台编辑了一下）。
之前邮件的剩余内容是： JVM Metaspace Max大小是默认的 256 MB，每次跑这个 Batch 的统计任务后用量就会增加十几M，这样最后就OOM了。 Flink 通过 Docker 运行的 1.12 版本，配置基本都是默认的，JVM这些没有额外设置什么。 任务的内容比较简单，查询一张Mysql的表，然后统计几个数据，SQL里用了 COUNT() FILTER () 这种语句，结果写入 Kafka。 代码中 使用 pipeline.jars 添加了所需要的 Mysql 和 Kafka 连接所需的 jar 包。 使用Blink的Batch mode，env_setting = EnvironmentSettings.new_instance().in_batch_mode().use_blink_planner().build() 整体和官方例子差不多，所以不太清楚是哪里有问题。希望能帮助分析下原因。 好的，我尝试 jstack / jmap看看是否能定位到原因。 -- Sent from: http://apache-flink.147419.n8.nabble.com/
