[hive] branch master updated: HIVE-23745: Avoid copying userpayload in task communicator (Dmitriy Fingerman, reviewed by Laszlo Bodor)

[tchoi]

This is an automated email from the ASF dual-hosted git repository.

tchoi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git


The following commit(s) were added to refs/heads/master by this push:
     new 1be7135f649 HIVE-23745: Avoid copying userpayload in task communicator 
(Dmitriy Fingerman, reviewed by Laszlo Bodor)
1be7135f649 is described below

commit 1be7135f649138fcb8523944545364070d8490f6
Author: Dmitriy Fingerman <dmitriy.finger...@gmail.com>
AuthorDate: Tue Oct 4 04:24:34 2022 -0400

    HIVE-23745: Avoid copying userpayload in task communicator (Dmitriy 
Fingerman, reviewed by Laszlo Bodor)
    
    Co-authored-by: Dmitriy Fingerman <dfinger...@cloudera.com>
---
 llap-common/src/java/org/apache/hadoop/hive/llap/tez/Converters.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/llap-common/src/java/org/apache/hadoop/hive/llap/tez/Converters.java 
b/llap-common/src/java/org/apache/hadoop/hive/llap/tez/Converters.java
index 83e5246b233..ba7664e7bf5 100644
--- a/llap-common/src/java/org/apache/hadoop/hive/llap/tez/Converters.java
+++ b/llap-common/src/java/org/apache/hadoop/hive/llap/tez/Converters.java
@@ -18,7 +18,7 @@ import java.io.IOException;
 import java.util.ArrayList;
 import java.util.List;
 
-import com.google.protobuf.ByteString;
+import com.google.protobuf.UnsafeByteOperations;
 import 
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.EntityDescriptorProto;
 import 
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.GroupInputSpecProto;
 import 
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.IOSpecProto;
@@ -179,7 +179,7 @@ public class Converters {
     if (userPayload != null) {
       UserPayloadProto.Builder payloadBuilder = UserPayloadProto.newBuilder();
       if (userPayload.hasPayload()) {
-        
payloadBuilder.setUserPayload(ByteString.copyFrom(userPayload.getPayload()));
+        
payloadBuilder.setUserPayload(UnsafeByteOperations.unsafeWrap(userPayload.getPayload()));
         payloadBuilder.setVersion(userPayload.getVersion());
       }
       builder.setUserPayload(payloadBuilder.build());