flinkcdc有人遇到过这种问题吗?

flinkcdc有人遇到过这种问题吗?flink内部分配slot一直在Disconnect TaskExecutor
2024-05-20 17:41:58,172 INFO org.apache.flink.runtime.jobmaster.JobMaster [] - Disconnect TaskExecutor container_1704787520409_4703773_01_000002(yj-nodemanager3-0023:8041) because: TaskExecutor akka.tcp://flink@yj-nodemanager3-0023:26651/user/rpc/taskmanager_0 has no more allocated slots for job de57c8101293cfd02d1e03260be7734d.
2024-05-20 17:41:58,172 INFO org.apache.flink.runtime.jobmaster.JobMaster [] - Disconnect TaskExecutor container_1704787520409_4703773_01_000058(yj-nodemanager3-0020:8041) because: TaskExecutor akka.tcp://flink@yj-nodemanager3-0020:11394/user/rpc/taskmanager_0 has no more allocated slots for job de57c8101293cfd02d1e03260be7734d.
2024-05-20 17:41:58,235 INFO org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Matching resource requirements against available resources.

展开
收起
夹心789 2024-05-28 16:48:41 139 分享 版权
0 条回答
写回答
取消 提交回答

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理