Simply setting config pipeline.object-reuse=true should work for that. Best, Zhanghao Chen ________________________________ From: Winterchill <809025...@qq.com.INVALID> Sent: Wednesday, April 23, 2025 20:12 To: dev <dev@flink.apache.org> Subject: [DISCUSS] FlinkSQL support enableObjectReuse to optimize CopyingChainingOutput
During our analysis of FlinkSQL, we found that the FlinkSQL data stream heavily uses `CopyingChainingOutput` for operator-to-operator data transmission. In the process, we observed that some operators, such as `WatermarkAssigner`, do not necessarily require the deep copy logic of `CopyingChainingOutput`. Additionally, we noticed that FlinkSQL does not support the `enableObjectReuse` parameter in `DataStream`. Based on this, we have the following questions: 1. Will FlinkSQL support `enableObjectReuse` in the future? 2. We would like try to modify FlinkSQL's internal logic to eliminate unnecessary deep copies. How can we do this safely? Do you have any suggestions?
