FlinkObject Reuse 数据重用 深拷贝 一些坑

Posted 2021-11-09 九师兄

文章目录

• 1.概述
• 2.场景再现
• • 2.1 chain
  • 2.2 不chian
• 3. 解决
• • 3.1 不使用深拷贝
  • 3.2 自己主动拷贝

1.概述

我们为了提高程序的性能使用了 Object Reuse 数据重用，这个东西的介绍请参考 【Flink】Object Reuse 模式（Stream API） 性能优化 chain 数据重用 不深拷贝 ，然后因为数据重用，一直没有出现问题。因此也没考虑。

但是今天出了问题。