版本: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...@126.com
|

回复