[incubator-celeborn] branch main updated: [CELEBORN-272][BUG] Don't do replication should directly use callback not wrappedCallback (#1205)

[an...@apache.org]

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

angerszhuuuu 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 ecc3a0e52 [CELEBORN-272][BUG] Don't do replication should directly use callback not wrappedCallback (#1205)
ecc3a0e52 is described below

commit ecc3a0e52f1949741bea24ac0d46b0eb035d563e
Author: Angerszhuuuu <an...@gmail.com>
AuthorDate: Mon Feb 6 11:28:12 2023 +0800

    [CELEBORN-272][BUG] Don't do replication should directly use callback not wrappedCallback (#1205)
---
 .../org/apache/celeborn/service/deploy/worker/PushDataHandler.scala   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala b/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala
index c3b999f53..c831f4914 100644
--- a/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala
+++ b/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala
@@ -337,7 +337,7 @@ class PushDataHandler extends BaseMessageHandler with Logging {
         }
       })
     } else {
-      wrappedCallback.onSuccess(ByteBuffer.wrap(Array[Byte]()))
+      callback.onSuccess(ByteBuffer.wrap(Array[Byte]()))
     }
 
     try {
@@ -559,7 +559,7 @@ class PushDataHandler extends BaseMessageHandler with Logging {
         }
       })
     } else {
-      wrappedCallback.onSuccess(ByteBuffer.wrap(Array[Byte]()))
+      callback.onSuccess(ByteBuffer.wrap(Array[Byte]()))
     }
 
     var index = 0