toolongframeexception
大家好: 我搭建了一个单机standealone 的flink用来测试mysql CDC,我发现每天晚上4点和4.30,我的taskmanager和jobmanager日志都有akka的TooLongFrameException,是BlobServerConnection报出来的,那个时候可能有定时任务在操作大量操作mysql数据库,我想问: 1. TooLongFrameException可能是mysql操作比较大造成的吗?如果是,有解决方法吗? 2. BlobServer是干嘛的?我一直认为blobserver是用来放job jar之类的,应该和cdc job的数据无关吧 3. 哪些情况可能造成TooLongFrameException? 感谢大家
回复:flink两阶段提交
多谢啦 回复的原邮件 | 发件人 | Feng Jin | | 日期 | 2023年10月08日 13:17 | | 收件人 | user-zh@flink.apache.org | | 抄送至 | | | 主题 | Re: flink两阶段提交 | hi, 可以参考这篇博客,描述的非常清晰: https://flink.apache.org/2018/02/28/an-overview-of-end-to-end-exactly-once-processing-in-apache-flink-with-apache-kafka-too/ Best, Feng On Sun, Sep 24, 2023 at 9:54 PM 海风 <18751805...@163.com> wrote: > 请教一下,flink的两阶段提交对于sink算子,预提交是在做检查点的哪个阶段触发的?预提交时具体是做了什么工作? > > >