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 b87a3a753bc..a3af7cec5d5 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; }