You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@celeborn.apache.org by et...@apache.org on 2023/03/08 01:35:15 UTC

[incubator-celeborn] branch CELEBORN-383 created (now 387b0506f)

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

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


      at 387b0506f [CELEBORN-383] Fix read data might fetch the wrong partition location.

This branch includes the following new commits:

     new 387b0506f [CELEBORN-383] Fix read data might fetch the wrong partition location.

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



[incubator-celeborn] 01/01: [CELEBORN-383] Fix read data might fetch the wrong partition location.

Posted by et...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

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

commit 387b0506f693653e5fd6cb4ba69ab3230a859e66
Author: Ethan Feng <et...@apache.org>
AuthorDate: Wed Mar 8 09:35:04 2023 +0800

    [CELEBORN-383] Fix read data might fetch the wrong partition location.
---
 .../src/main/java/org/apache/celeborn/client/read/RssInputStream.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/client/src/main/java/org/apache/celeborn/client/read/RssInputStream.java b/client/src/main/java/org/apache/celeborn/client/read/RssInputStream.java
index 66a184692..ca54601a3 100644
--- a/client/src/main/java/org/apache/celeborn/client/read/RssInputStream.java
+++ b/client/src/main/java/org/apache/celeborn/client/read/RssInputStream.java
@@ -59,7 +59,7 @@ public abstract class RssInputStream extends InputStream {
           conf,
           clientFactory,
           shuffleKey,
-          locations,
+          Arrays.copyOf(locations,locations.length),
           attempts,
           attemptNumber,
           startMapIndex,