1.概述
在做flink任务的时候，报错
Timed out waiting for a node assignment
详细错误如下
2.源码
在SourceCoordinator中我们调用了start方法启动.启动方法主要做了2件事
- 创建Enumerator
- 启动Enumerator
本文转载自: https://blog.csdn.net/qq_21383435/article/details/125182837
版权归原作者 九师兄 所有， 如有侵权，请联系我们删除。
版权归原作者 九师兄 所有， 如有侵权，请联系我们删除。