大家好:
我搭建了一个单机standealone 的flink用来测试mysql
CDC,我发现每天晚上4点和4.30,我的taskmanager和jobmanager日志都有akka的TooLongFrameException,是BlobServerConnection报出来的,那个时候可能有定时任务在操作大量操作mysql数据库,我想问:
1. TooLongFrameException可能是mysql操作比较大造成的吗?如果是,有解决方法吗?
2. BlobServer是干嘛的?我一直认为blobserver是用来放job jar之类的,应该和cdc job的
, July 3, 2022 16:18
To: user-zh@flink.apache.org
Subject: 任务出现TooLongFrameException: Adjusted frame length exceeds问题
版本:flink-1.14
任务:FlinkSQL,从kafka消费,TVF统计窗口输出
出现问题:无论是Flink JM和TM都出现了TooLongFrameException: Adjusted frame length exceeds
10485760: 369295622 - discarded
[cid:4dfb897b$1$181c32399ec
你好,能提供下完整的 jm/tm 侧报错日志吗?
Best,
Zhanghao Chen
From: 谭家良
Sent: Sunday, July 3, 2022 16:18
To: user-zh@flink.apache.org
Subject: 任务出现TooLongFrameException: Adjusted frame length exceeds问题
版本:flink-1.14
任务:FlinkSQL,从kafka消费,TVF统计窗口输出
出现问题:无论是Flink JM和TM都出现了
版本:flink-1.14任务:FlinkSQL,从kafka消费,TVF统计窗口输出出现问题:无论是Flink
JM和TM都出现了TooLongFrameException: Adjusted frame length exceeds 10485760:
369295622 - discarded
我看有部分任务会经常出现这种问题,想请教一下几个问题1. 出现这种问题的原因是什么?是JM与TM的通信问题还是TM与TM之间的通信问题?2.
这种情况的出现是否会带来数据丢失?3. 无论是jm和tm都会出现这种情况,有什么好的解决办法?
| |
谭家良
|
|
tanjl_w