[ 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)