[incubator-celeborn] branch main updated: [CELEBORN-316][FOLLOWUP] Should not wrap CelebornIOException with CelebornIOException (#1264)

[angerszhuuuu]

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 f7948190 [CELEBORN-316][FOLLOWUP] Should not wrap CelebornIOException 
with CelebornIOException (#1264)
f7948190 is described below

commit f7948190cf8eb9e6126603b99c6f494c7748cb8c
Author: Angerszhuuuu <angers....@gmail.com>
AuthorDate: Thu Feb 23 11:48:46 2023 +0800

    [CELEBORN-316][FOLLOWUP] Should not wrap CelebornIOException with 
CelebornIOException (#1264)
---
 client/src/main/java/org/apache/celeborn/client/write/DataPusher.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/client/src/main/java/org/apache/celeborn/client/write/DataPusher.java 
b/client/src/main/java/org/apache/celeborn/client/write/DataPusher.java
index 7ad87791..a75b8412 100644
--- a/client/src/main/java/org/apache/celeborn/client/write/DataPusher.java
+++ b/client/src/main/java/org/apache/celeborn/client/write/DataPusher.java
@@ -127,6 +127,8 @@ public class DataPusher {
                 }
                 pushData(task);
                 reclaimTask(task);
+              } catch (CelebornIOException e) {
+                exceptionRef.set(e);
               } catch (InterruptedException | IOException e) {
                 exceptionRef.set(new CelebornIOException(e));
               }