Flink collector 非常慢 一次尴尬的 排查错误方向 chain 与 不chain 的 区别

Posted 2021-06-26 九师兄

文章目录

• 1.概述
• 2. 不chain的流程
• • 2.1 测试代码
• 3. chain在一起
• • 3.1 测试类

1.概述

是这样的，我用arthas监控测试环境的flink任务，然后想看看任务那里慢了。

但是发现一个问题

请问我们使用row类型传递数据，flink的内置数据类型，为啥看起来这么耗时

有时候耗时就很厉害，这个是怎么回事 有办法优化吗࿱