apache-flink - 取消的 flink 作业没有释放 tm 和 jm 的使用内存
问题描述
我使用 flink 版本 1.13.1
我在flink集群中运行了一个flink作业,但是发现当我在web-ui中取消flink作业时,taskmanager和jobmanager的使用内存没有被释放。并且在我的工作中有一些db连接和redis连接,当工作取消时,连接也没有被释放。
我应该在 ProcessFunction 的“关闭”函数中关闭所有连接并将所有全局变量设置为 null 吗?
我使用flink的kafka连接,我应该做些什么吗?或者当我取消工作时它可以是正确的?
解决方案
推荐阅读
- laravel - 无法打开流或文件 laravel\storage/logs/laravel.log: failed to open stream on plesk server
- laravel - 如何通过控制器访问我的 .env 电子邮件变量
- javascript - 我应该提交由 laravel mix 生成的 css 和 js 吗?
- r - 使用 R 中特定列的值及其前一列逐行检查条件
- javascript - Javascript 事件在 ionic 中的地图标记中不起作用
- css - 标题中间穿过两个半列 - 引导
- javascript - 如何在图像滑块上的透明框中覆盖文本?
- shell - 如何使用 grep 命令修剪日志文件
- apache - 无法将 /modules/mod_dav_svn.so 加载到服务器中
- python - 无法从 virtualenv 内部运行 daphne