You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ae...@apache.org on 2018/09/07 14:40:32 UTC
hadoop git commit: HDDS-408. Read (getKey) operation is very slow.
Contributed by Nandakumar.
Repository: hadoop
Updated Branches:
refs/heads/trunk 396ce7b88 -> be1ec005f
HDDS-408. Read (getKey) operation is very slow.
Contributed by Nandakumar.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/be1ec005
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/be1ec005
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/be1ec005
Branch: refs/heads/trunk
Commit: be1ec005f1c725d775b92d946fa46b1f17f23b4c
Parents: 396ce7b
Author: Anu Engineer <ae...@apache.org>
Authored: Fri Sep 7 07:36:24 2018 -0700
Committer: Anu Engineer <ae...@apache.org>
Committed: Fri Sep 7 07:36:24 2018 -0700
----------------------------------------------------------------------
.../org/apache/hadoop/ozone/client/io/OzoneInputStream.java | 5 +++++
.../main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java | 3 +--
2 files changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/be1ec005/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/OzoneInputStream.java
----------------------------------------------------------------------
diff --git a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/OzoneInputStream.java b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/OzoneInputStream.java
index c2ff979..e1f65e6 100644
--- a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/OzoneInputStream.java
+++ b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/OzoneInputStream.java
@@ -45,6 +45,11 @@ public class OzoneInputStream extends InputStream {
}
@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();
}
http://git-wip-us.apache.org/repos/asf/hadoop/blob/be1ec005/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java
----------------------------------------------------------------------
diff --git a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java
index e9a684e..330eba8 100644
--- a/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java
+++ b/hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/rpc/RpcClient.java
@@ -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());
}
@Override
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org