【发布时间】:2022-10-07 13:10:14
【问题描述】:
我有一个Apache Flink 集群(1.14.5)运行Kubernetes (AKS).集群正在运行会话模式.我正在触发批处理作业定期给它。 之前的工作经理jvm元空间被配置为 256mb 然后后来增加到512 MB.每当我运行批处理管道 3 到 4 次时,它都会完全填满元空间,然后它不会加载任何新的批处理作业,直到我重新启动作业管理器。 我没有在应用程序代码中看到任何类加载器泄漏。触发的批处理管道也完全运行并标记为 FINISHED 状态。
自从我重新启动集群时,我从未见过作业管理器的元空间下降,它总是随着每个新的批处理管道运行而不断增长,并最终开始拒绝新的批处理作业。
我需要知道 flink 如何定期管理/清理这个作业管理器元空间,或者它根本不这样做。请建议/帮助。
标签: apache-flink