toolongframeexception

2023-10-08 文章 Jiacheng Jiang
大家好:

   我搭建了一个单机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两阶段提交

2023-10-08 文章 海风
多谢啦



 回复的原邮件 
| 发件人 | 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算子,预提交是在做检查点的哪个阶段触发的?预提交时具体是做了什么工作?
>
>
>