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

在生产中发现有个别Flink SQL 1.11作业的container线程数很高,查看Thread Dump发现有很多名为LeaseRenewer 的线程处于TIMED_WAITING状态,目前只能复现其现象,但是无法定位原因,不知道社区是否有类似经历的小伙伴呢? Flink version: 1....

Re: Flink 1.11版本LeaseRenewer线程不释放怎么办?

如题所述,辛苦回答下,感谢!*来自志愿者整理的flink邮件归档

Flink Reporter 是有专门的线程吗?

Flink Reporter 是有专门的线程吗?

在 Flink 算子中使用多线程如何保证不丢数据?

在 Flink 算子中使用多线程如何保证不丢数据?

分析痛点 笔者线上有一个 Flink 任务消费 Kafka 数据,将数据转换后,在 Flink 的 Sink 算子内部调用第三方 api 将数据上报到第三方的数据分析平台。这里使用批量同步 api,即:每 50 条数据请求一次第三方接口,可以通过批量 api 来提高请求效率。由于调用的外网接口,所以...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。