You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by gr...@apache.org on 2016/02/23 08:43:48 UTC
phoenix git commit: LP-2705 Downgrade warn logging in region observer
Repository: phoenix
Updated Branches:
refs/heads/4.x-HBase-1.0 237af76ce -> f3e5831b2
LP-2705 Downgrade warn logging in region observer
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/f3e5831b
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/f3e5831b
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/f3e5831b
Branch: refs/heads/4.x-HBase-1.0
Commit: f3e5831b2981c7f4cfe4fd7c827bafd3388527f6
Parents: 237af76
Author: Gabriel Reid <ga...@ngdata.com>
Authored: Tue Feb 23 08:42:34 2016 +0100
Committer: Gabriel Reid <ga...@ngdata.com>
Committed: Tue Feb 23 08:43:48 2016 +0100
----------------------------------------------------------------------
.../phoenix/coprocessor/UngroupedAggregateRegionObserver.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/f3e5831b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java
index a12a2d8..a800f16 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java
@@ -152,7 +152,7 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver
}
Mutation[] mutationArray = new Mutation[mutations.size()];
// TODO: should we use the one that is all or none?
- logger.warn("Committing bactch of " + mutations.size() + " mutations for " + region.getRegionInfo().getTable().getNameAsString());
+ logger.debug("Committing bactch of " + mutations.size() + " mutations for " + region.getRegionInfo().getTable().getNameAsString());
region.batchMutate(mutations.toArray(mutationArray), HConstants.NO_NONCE, HConstants.NO_NONCE);
}
@@ -209,7 +209,7 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver
byte[] descRowKeyTableBytes = scan.getAttribute(UPGRADE_DESC_ROW_KEY);
boolean isDescRowKeyOrderUpgrade = descRowKeyTableBytes != null;
if (isDescRowKeyOrderUpgrade) {
- logger.warn("Upgrading row key for " + region.getRegionInfo().getTable().getNameAsString());
+ logger.debug("Upgrading row key for " + region.getRegionInfo().getTable().getNameAsString());
projectedTable = deserializeTable(descRowKeyTableBytes);
try {
writeToTable = PTableImpl.makePTable(projectedTable, true);