[ 
https://issues.apache.org/jira/browse/APEXCORE-648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15874903#comment-15874903
 ] 

Vlad Rozov commented on APEXCORE-648:
-------------------------------------

[~brightchen] Please see https://github.com/vrozov/apex-core/tree/APEXCORE-648. 
Can you benchmark the fix and compare old and new behavior.

> Unnecessary byte array copy in DefaultStatefulStreamCodec.toDataStatePair()
> ---------------------------------------------------------------------------
>
>                 Key: APEXCORE-648
>                 URL: https://issues.apache.org/jira/browse/APEXCORE-648
>             Project: Apache Apex Core
>          Issue Type: Bug
>            Reporter: Vlad Rozov
>            Assignee: Vlad Rozov
>            Priority: Minor
>
> DefaultStatefulStreamCodec.toDataStatePair() calls Kryo Output.toBytes() that 
>  creates new byte[] and copies serialized data to the newly allocated array. 
> It is not necessary as the output of toDataStatePair() will be copied again 
> in PayloadTuple.getSerializedTuple().



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to