[incubator-celeborn] branch main updated: [CELEBORN-322][Flink] Copy out message if it‘s readData only. (#1255)

[ethanfeng]

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

ethanfeng pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git


The following commit(s) were added to refs/heads/main by this push:
     new 5dd5e972 [CELEBORN-322][Flink] Copy out message if it‘s readData only. 
(#1255)
5dd5e972 is described below

commit 5dd5e97225fee90ec1e5d5178137b89bac36ee29
Author: Ethan Feng <ethanf...@apache.org>
AuthorDate: Tue Feb 21 15:51:13 2023 +0800

    [CELEBORN-322][Flink] Copy out message if it‘s readData only. (#1255)
---
 .../java/org/apache/celeborn/plugin/flink/protocol/ReadData.java     | 5 +++++
 .../java/org/apache/celeborn/common/network/protocol/Message.java    | 2 +-
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/protocol/ReadData.java
 
b/client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/protocol/ReadData.java
index 0932b094..644aeb28 100644
--- 
a/client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/protocol/ReadData.java
+++ 
b/client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/protocol/ReadData.java
@@ -29,6 +29,11 @@ public final class ReadData extends RequestMessage {
   private final long offset;
   private ByteBuf flinkBuffer;
 
+  @Override
+  public boolean needCopyOut() {
+    return true;
+  }
+
   public ReadData(long streamId, int backlog, long offset) {
     this.streamId = streamId;
     this.backlog = backlog;
diff --git 
a/common/src/main/java/org/apache/celeborn/common/network/protocol/Message.java 
b/common/src/main/java/org/apache/celeborn/common/network/protocol/Message.java
index 4129ccb8..d2bbd55a 100644
--- 
a/common/src/main/java/org/apache/celeborn/common/network/protocol/Message.java
+++ 
b/common/src/main/java/org/apache/celeborn/common/network/protocol/Message.java
@@ -56,7 +56,7 @@ public abstract class Message implements Encodable {
 
   /** Whether the body should be copied out in frame decoder. */
   public boolean needCopyOut() {
-    return true;
+    return false;
   }
 
   protected boolean equals(Message other) {