You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ra...@apache.org on 2017/12/22 14:31:29 UTC
phoenix git commit: PHOENIX-4481 Some IT tests are failing with wrong
bytes count after updating statistics(Rajeshbabu)
Repository: phoenix
Updated Branches:
refs/heads/5.x-HBase-2.0 0fcd9de8b -> 91bfaf0e7
PHOENIX-4481 Some IT tests are failing with wrong bytes count after updating statistics(Rajeshbabu)
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/91bfaf0e
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/91bfaf0e
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/91bfaf0e
Branch: refs/heads/5.x-HBase-2.0
Commit: 91bfaf0e7f2ce67d30d54ef162771af4c839fc26
Parents: 0fcd9de
Author: Rajeshbabu Chintaguntla <ra...@apache.org>
Authored: Fri Dec 22 20:01:08 2017 +0530
Committer: Rajeshbabu Chintaguntla <ra...@apache.org>
Committed: Fri Dec 22 20:01:08 2017 +0530
----------------------------------------------------------------------
.../apache/phoenix/schema/stats/DefaultStatisticsCollector.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/91bfaf0e/phoenix-core/src/main/java/org/apache/phoenix/schema/stats/DefaultStatisticsCollector.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/schema/stats/DefaultStatisticsCollector.java b/phoenix-core/src/main/java/org/apache/phoenix/schema/stats/DefaultStatisticsCollector.java
index 42f8b91..853c24d 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/stats/DefaultStatisticsCollector.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/stats/DefaultStatisticsCollector.java
@@ -334,7 +334,7 @@ class DefaultStatisticsCollector implements StatisticsCollector {
incrementRow = false;
}
}
- int kvLength = CellUtil.estimatedSerializedSizeOf(cell);
+ int kvLength = KeyValueUtil.getSerializedSize(cell, true);
long byteCount = gps.getFirst() + kvLength;
gps.setFirst(byteCount);
if (byteCount >= guidePostDepth) {