debug一下serializer和copy方法，你就能看到是哪个Output实现调用的这些方法了  

0 0

  目前就了解到flink根据算否开启算子链有不同的Output实现，不同的Output实现的方式不同。要更深入的了解你得自己看下了

另外关于binaryRowData为什么可以，RowDataSerializer使用UNSFAE类的方法去做的序列化和反序列化，这里应该采用了小端法的方式，导致你的Long数据通过getInt也能正确反序列化出来
https://blog.csdn.net/u012861978/article/details/51906546

0 0

  我是说判断是否开启算子链以后，走序列化还是copy的逻辑

0 0

关于这个binaryrowdata，你可以看下 org.apache.flink.table.runtime.typeutils.RowDataSerializer这个类的方法的调用，如果关闭算子链会走serializer和deserializer的方法，否则走的是copy。
之前做更改是为了同步场景下的性能传输

  想了解或咨询更多有关袋鼠云大数据产品、行业解决方案、客户案例的朋友，浏览袋鼠云官网：

https://www.dtstack.com/?src=bbs

同时，欢迎对大数据开源项目有兴趣的同学加入「袋鼠云开源框架钉钉技术群」，交流最新开源技术信息，群号码：30537511，项目地址：

https://github.com/DTStack/chunjun  

0 0

  求大佬赐教之前这个更改的考虑，仅仅是为了提高传输性能？  

0 0