@@ -44,6 +44,11 @@ public class OzoneInputStream extends InputStream {
return inputStream.read();
}
+ @Override
+ public int read(byte[] b, int off, int len) throws IOException {
+ return inputStream.read(b, off, len);
+ }
+
@Override
public synchronized void close() throws IOException {
inputStream.close();
@@ -492,8 +492,7 @@ public class RpcClient implements ClientProtocol {
ChunkGroupInputStream.getFromOmKeyInfo(
keyInfo, xceiverClientManager, storageContainerLocationClient,
requestId);
- return new OzoneInputStream(
- (ChunkGroupInputStream)lengthInputStream.getWrappedStream());
+ return new OzoneInputStream(lengthInputStream.getWrappedStream());