[incubator-celeborn] branch main updated: Revert "[CELEBORN-322][Flink] Copy out message if it‘s readData only."

[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 c6496559 Revert "[CELEBORN-322][Flink] Copy out message if it‘s 
readData only."
c6496559 is described below

commit c6496559331d0b27b0d3969217ed4af7285db3b0
Author: Ethan Feng <ethanf...@apache.org>
AuthorDate: Tue Feb 21 14:48:08 2023 +0800

    Revert "[CELEBORN-322][Flink] Copy out message if it‘s readData only."
    
    This reverts commit 0aa37ed7d3a3340c589f0f5d3d3ecbd8dcae83ad.
---
 .../java/org/apache/celeborn/plugin/flink/protocol/ReadData.java     | 5 -----
 .../java/org/apache/celeborn/common/network/protocol/Message.java    | 2 +-
 2 files changed, 1 insertion(+), 6 deletions(-)

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 644aeb28..0932b094 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,11 +29,6 @@ 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 d2bbd55a..4129ccb8 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 false;
+    return true;
   }
 
   protected boolean equals(Message other) {