你好,能提供下完整的 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