diff --git a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt index 8d2b35b1001..4b838086781 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt +++ b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt @@ -144,6 +144,8 @@ Release 2.4.0 - UNRELEASED HDFS-5986. Capture the number of blocks pending deletion on namenode webUI. (cnauroth) + HDFS-6070. Cleanup use of ReadStatistics in DFSInputStream. (wang) + OPTIMIZATIONS HDFS-5790. LeaseManager.findPath is very slow when many leases need recovery diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/DFSInputStream.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/DFSInputStream.java index 9663712a1e3..5dbef718f30 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/DFSInputStream.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/DFSInputStream.java @@ -659,14 +659,11 @@ implements ByteBufferReadable, CanSetDropBehind, CanSetReadahead, int nRead, BlockReader blockReader) { if (nRead <= 0) return; if (blockReader.isShortCircuit()) { - readStatistics.totalBytesRead += nRead; - readStatistics.totalLocalBytesRead += nRead; - readStatistics.totalShortCircuitBytesRead += nRead; + readStatistics.addShortCircuitBytes(nRead); } else if (blockReader.isLocal()) { - readStatistics.totalBytesRead += nRead; - readStatistics.totalLocalBytesRead += nRead; + readStatistics.addLocalBytes(nRead); } else { - readStatistics.totalBytesRead += nRead; + readStatistics.addRemoteBytes(nRead); } }