You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@celeborn.apache.org by zh...@apache.org on 2023/03/27 09:03:11 UTC

[incubator-celeborn] branch main updated: [CELEBORN-479][FOLLOWUP] Return empty tasks instead of null to avoid NPE (#1388)

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

zhouky 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 9d9a2d4ea [CELEBORN-479][FOLLOWUP] Return empty tasks instead of null to avoid NPE (#1388)
9d9a2d4ea is described below

commit 9d9a2d4ea85ff918ced7abb7a8f148af4450c40f
Author: Angerszhuuuu <an...@gmail.com>
AuthorDate: Mon Mar 27 17:03:06 2023 +0800

    [CELEBORN-479][FOLLOWUP] Return empty tasks instead of null to avoid NPE (#1388)
---
 .../src/main/java/org/apache/celeborn/client/write/DataPushQueue.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/client/src/main/java/org/apache/celeborn/client/write/DataPushQueue.java b/client/src/main/java/org/apache/celeborn/client/write/DataPushQueue.java
index 40e7626c5..2506d3689 100644
--- a/client/src/main/java/org/apache/celeborn/client/write/DataPushQueue.java
+++ b/client/src/main/java/org/apache/celeborn/client/write/DataPushQueue.java
@@ -123,7 +123,7 @@ public class DataPushQueue {
         ExceptionUtils.wrapAndThrowIOException(ie);
       }
     }
-    return null;
+    return tasks;
   }
 
   public boolean addPushTask(PushTask pushTask) throws InterruptedException {