diff --git a/src/main/java/org/apache/hadoop/hbase/HServerLoad.java b/src/main/java/org/apache/hadoop/hbase/HServerLoad.java index 2ab7470..0c80d34 100644 --- a/src/main/java/org/apache/hadoop/hbase/HServerLoad.java +++ b/src/main/java/org/apache/hadoop/hbase/HServerLoad.java @@ -115,9 +115,9 @@ implements WritableComparable { */ private int storefileIndexSizeMB; /** the current total read requests made to region */ - private int readRequestsCount; + private long readRequestsCount; /** the current total write requests made to region */ - private int writeRequestsCount; + private long writeRequestsCount; /** the total compacting key values in currently running compaction */ private long totalCompactingKVs; /** the completed count of key values in currently running compaction */ @@ -161,7 +161,7 @@ implements WritableComparable { final int memstoreSizeMB, final int storefileIndexSizeMB, final int rootIndexSizeKB, final int totalStaticIndexSizeKB, final int totalStaticBloomSizeKB, - final int readRequestsCount, final int writeRequestsCount, + final long readRequestsCount, final long writeRequestsCount, final long totalCompactingKVs, final long currentCompactedKVs) { this.name = name; this.stores = stores; @@ -345,8 +345,8 @@ implements WritableComparable { this.storefileSizeMB = WritableUtils.readVInt(in); this.memstoreSizeMB = WritableUtils.readVInt(in); this.storefileIndexSizeMB = WritableUtils.readVInt(in); - this.readRequestsCount = WritableUtils.readVInt(in); - this.writeRequestsCount = WritableUtils.readVInt(in); + this.readRequestsCount = WritableUtils.readVLong(in); + this.writeRequestsCount = WritableUtils.readVLong(in); this.rootIndexSizeKB = WritableUtils.readVInt(in); this.totalStaticIndexSizeKB = WritableUtils.readVInt(in); this.totalStaticBloomSizeKB = WritableUtils.readVInt(in); @@ -365,8 +365,8 @@ implements WritableComparable { WritableUtils.writeVInt(out, storefileSizeMB); WritableUtils.writeVInt(out, memstoreSizeMB); WritableUtils.writeVInt(out, storefileIndexSizeMB); - WritableUtils.writeVInt(out, readRequestsCount); - WritableUtils.writeVInt(out, writeRequestsCount); + WritableUtils.writeVLong(out, readRequestsCount); + WritableUtils.writeVLong(out, writeRequestsCount); WritableUtils.writeVInt(out, rootIndexSizeKB); WritableUtils.writeVInt(out, totalStaticIndexSizeKB); WritableUtils.writeVInt(out, totalStaticBloomSizeKB);