You can disable those copies via ExecutionConfig.enableObjectReuse(), which you
can get from the StreamExecutionEnvironment via getConfig().
> On 12. Feb 2018, at 04:00, chen <eric__...@126.com> wrote:
> Actually our team have our own Stream Engine, we tested our engine and flink,
> find out when we aggregate the stream data, the throughput is decreasing
> very fast.
> So we catch the stack and find out a deep copy in flink.
> In different operator, there will be
> org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.copy between
> in different operator.
> Sent from: