diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/RawLocalFileSystem.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/RawLocalFileSystem.java index d5f545b460d7e..65c4b1c7e7b65 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/RawLocalFileSystem.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/RawLocalFileSystem.java @@ -32,6 +32,7 @@ import java.io.OutputStream; import java.io.FileDescriptor; import java.net.URI; +import java.nio.Buffer; import java.nio.ByteBuffer; import java.nio.channels.AsynchronousFileChannel; import java.nio.channels.CompletionHandler; @@ -425,7 +426,7 @@ public void completed(Integer result, Integer rangeIndex) { channel.read(buffer, range.getOffset() + buffer.position(), rangeIndex, this); } else { // Flip the buffer and declare success. - buffer.flip(); + ((Buffer)(buffer)).flip(); range.getData().complete(buffer); } } diff --git a/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AInputStream.java b/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AInputStream.java index f5ea8467dce8c..171365c70c31f 100644 --- a/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AInputStream.java +++ b/hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3AInputStream.java @@ -24,6 +24,7 @@ import java.io.InputStream; import java.io.InterruptedIOException; import java.net.SocketTimeoutException; +import java.nio.Buffer; import java.nio.ByteBuffer; import java.util.List; import java.util.Optional; @@ -1029,7 +1030,7 @@ private void readSingleRange(FileRange range, ByteBuffer buffer) { LOG.debug("Start reading {} from {} ", range, getPathStr()); if (range.getLength() == 0) { // a zero byte read. - buffer.flip(); + ((Buffer)(buffer)).flip(); range.getData().complete(buffer); return; } @@ -1092,7 +1093,7 @@ private void populateBuffer(FileRange range, readByteArray(objectContent, range, tmp, offset, currentLength); return null; }); - buffer.flip(); + ((Buffer)(buffer)).flip(); } else { // there is no use of a temp byte buffer, or buffer.put() calls, // so flip() is not needed.