flink mongodb cdc source多个并行度时是不是有一个额外的职责?

flink mongodb cdc source多个并行度时是不是有一个source task有额外的职责?
我发现我这里75个并行度每次checkpoint时都是74个很快完成,有一个卡很久(十几分钟)完成,或者卡很久后oom?

展开
收起
真的很搞笑 2023-09-27 07:55:57 134 分享 版权
1 条回答
写回答
取消 提交回答
  • flink任务共享slot,下游单并行度导致的吧,可以看看单并行度的算子是不是就是在oom的TM上,此回答整理自钉群“Flink CDC 社区”

    2023-09-27 14:57:39
    赞同 展开评论

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

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