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 <[email protected]>
Authored: Tue Feb 23 08:42:34 2016 +0100
Committer: Gabriel Reid <[email protected]>
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);

Reply via email to