HADOOP-13723. AliyunOSSInputStream#read() should update read bytes stat correctly. Contributed by Mingliang Liu
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d9f73f1b Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d9f73f1b Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d9f73f1b Branch: refs/heads/HADOOP-13070 Commit: d9f73f1b7cd893a7d88baa9bfd1b809a5dec9e59 Parents: ae51b11 Author: Mingliang Liu <lium...@apache.org> Authored: Thu Oct 13 17:05:28 2016 -0700 Committer: Mingliang Liu <lium...@apache.org> Committed: Thu Oct 13 22:33:55 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/hadoop/fs/aliyun/oss/AliyunOSSInputStream.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/d9f73f1b/hadoop-tools/hadoop-aliyun/src/main/java/org/apache/hadoop/fs/aliyun/oss/AliyunOSSInputStream.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-aliyun/src/main/java/org/apache/hadoop/fs/aliyun/oss/AliyunOSSInputStream.java b/hadoop-tools/hadoop-aliyun/src/main/java/org/apache/hadoop/fs/aliyun/oss/AliyunOSSInputStream.java index b87a3a7..a3af7ce 100644 --- a/hadoop-tools/hadoop-aliyun/src/main/java/org/apache/hadoop/fs/aliyun/oss/AliyunOSSInputStream.java +++ b/hadoop-tools/hadoop-aliyun/src/main/java/org/apache/hadoop/fs/aliyun/oss/AliyunOSSInputStream.java @@ -123,7 +123,7 @@ public class AliyunOSSInputStream extends FSInputStream { } if (statistics != null && byteRead >= 0) { - statistics.incrementBytesRead(1); + statistics.incrementBytesRead(byteRead); } return byteRead; } --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
