Hi,
感谢反馈，看上去是一个 bug。可以在 Apache JIRA [1] 上新建一个 ticket 吗？
[1] https://issues.apache.org/jira
> On May 25, 2022, at 11:35, 邹璨 wrote:
>
> flink版本: 1.14.3
> 模块：connectors/kafka
> 问题描述：
> 我在使用kafka分区动态发现时发生了WakeupException，导致Job失败。异常信息如下
>
> 2022-05-10 15:08:03
> java.lang.RuntimeException: One or
flink版本: 1.14.3
模块：connectors/kafka
问题描述：
我在使用kafka分区动态发现时发生了WakeupException，导致Job失败。异常信息如下
2022-05-10 15:08:03
java.lang.RuntimeException: One or more fetchers have encountered exception
at
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager
