kafkaTimedoutwaitingforanodeassignment

在做flink任务的时候，报错 Timed out waiting for a node assignment 详细错误如下

在SourceCoordinator中我们调用了start方法启动.启动方法主要做了2件事

1. 创建Enumerator


2. 启动Enumerator

以上是关于kafkaTimed out waiting for a node assignment的主要内容，如果未能解决你的问题，请参考以下文章

MessagingTimeout: Timed out waiting for a reply to message ID

终端 timed out waiting for input: auto-logout解决！

Timed out waiting for process (xxx) to appear on错误

Timed out waiting for process (xxx) to appear on错误

vscode+php+xdebug Time-out connecting to client (Waited: 200 ms)

(筆記) Edge wait & Level wait (verilog)