hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From x...@apache.org
Subject hadoop git commit: HDDS-627. OzoneFS read from an MR Job throws java.lang.ArrayIndexOutOfBoundsException. Contributed by Mukul Kumar Singh.
Date Thu, 11 Oct 2018 22:34:08 GMT
Repository: hadoop
Updated Branches:
  refs/heads/ozone-0.3 43ff80139 -> 72ac4e823


HDDS-627. OzoneFS read from an MR Job throws java.lang.ArrayIndexOutOfBoundsException. Contributed
by Mukul Kumar Singh.

(cherry picked from commit c05b260069511f2993a67683555ed2e1aea49a0a)


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/72ac4e82
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/72ac4e82
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/72ac4e82

Branch: refs/heads/ozone-0.3
Commit: 72ac4e823867696e5debaba05efe4579333907e9
Parents: 43ff801
Author: Xiaoyu Yao <xyao@apache.org>
Authored: Thu Oct 11 15:02:18 2018 -0700
Committer: Xiaoyu Yao <xyao@apache.org>
Committed: Thu Oct 11 15:12:06 2018 -0700

----------------------------------------------------------------------
 .../org/apache/hadoop/ozone/client/io/ChunkGroupInputStream.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hadoop/blob/72ac4e82/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/ChunkGroupInputStream.java
----------------------------------------------------------------------
diff --git a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/ChunkGroupInputStream.java
b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/ChunkGroupInputStream.java
index 2b10578..2f17035 100644
--- a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/ChunkGroupInputStream.java
+++ b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/ChunkGroupInputStream.java
@@ -129,7 +129,8 @@ public class ChunkGroupInputStream extends InputStream implements Seekable
{
       totalReadLen += numBytesRead;
       off += numBytesRead;
       len -= numBytesRead;
-      if (current.getRemaining() <= 0) {
+      if (current.getRemaining() <= 0 &&
+        ((currentStreamIndex + 1) < streamEntries.size())) {
         currentStreamIndex += 1;
       }
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org


Mime
View raw message