首页 > 解决方案 > 取消的 flink 作业没有释放 tm 和 jm 的使用内存

问题描述

我使用 flink 版本 1.13.1

我在flink集群中运行了一个flink作业,但是发现当我在web-ui中取消flink作业时,taskmanager和jobmanager的使用内存没有被释放。并且在我的工作中有一些db连接和redis连接,当工作取消时,连接也没有被释放。

我应该在 ProcessFunction 的“关闭”函数中关闭所有连接并将所有全局变量设置为 null 吗?

我使用flink的kafka连接,我应该做些什么吗?或者当我取消工作时它可以是正确的?

标签: apache-flinkflink-streaming

解决方案


推荐阅读