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/
