你好,能提供下完整的 jm/tm 侧报错日志吗?

Best,
Zhanghao Chen
________________________________
From: 谭家良 <tanjl_w...@126.com>
Sent: Sunday, July 3, 2022 16:18
To: user-zh@flink.apache.org <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$Coremail$tanjl_work$126.com]

我看有部分任务会经常出现这种问题,想请教一下几个问题
1. 出现这种问题的原因是什么?是JM与TM的通信问题还是TM与TM之间的通信问题?
2. 这种情况的出现是否会带来数据丢失?
3. 无论是jm和tm都会出现这种情况,有什么好的解决办法?
<https://maas.mail.163.com/dashi-web-extend/html/proSignature.html?ftlId=1&name=%E8%B0%AD%E5%AE%B6%E8%89%AF&uid=tanjl_work%40126.com&iconUrl=https%3A%2F%2Fmail-online.nosdn.127.net%2Fsm266e1d2e26af9f759edc476d7a2a0758.jpg&items=%5B%22tanjl_work%40126.com%22%5D>
[https://mail-online.nosdn.127.net/sm266e1d2e26af9f759edc476d7a2a0758.jpg]
谭家良
tanjl_w...@126.com

回复