Deep Copy in FLINK, Kryo Copy is used in the different operator

Posted by chen on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Deep-Copy-in-FLINK-Kryo-Copy-is-used-in-the-different-operator-tp18288.html

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: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/