You might also be able to make Flink use a better serializer than
Kryo. Flink falls back to Kryo when it can't use its own serializers,
For example, it might help to make your type a POJO.
On Wed, Feb 14, 2018 at 3:38 PM, Aljoscha Krettek <aljos...@apache.org> wrote:
> 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: