开发者社区> 问答> 正文

Flink 1.11版本LeaseRenewer为什么线程不释放?

在生产中发现有个别Flink SQL 1.11作业的container线程数很高,查看Thread Dump发现有很多名为LeaseRenewer

的线程处于TIMED_WAITING状态,目前只能复现其现象,但是无法定位原因,不知道社区是否有类似经历的小伙伴呢?

Flink version: 1.11

State backend:filesystem

checkpoint interval: 60s

*来自志愿者整理的flink邮件归档

展开
收起
小阿怪 2021-12-06 12:19:17 1028 0
1 条回答
写回答
取消 提交回答
  • 我记得 LeaseRenewer 是 JVM 级别的,线程个数应该和用到的 HDFS 集群数目相同。

    你看看它们具体的线程名是不是完全相同(比如都是 user1@cluserA)?还有 HDFS client 的版本是什么? *来自志愿者整理的flink邮件归档

    2021-12-06 13:22:08
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载