You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ma...@apache.org on 2016/09/20 18:05:43 UTC
[20/47] phoenix git commit: PHOENIX-3275 Reduce logging level of
mutable secondary index logging
PHOENIX-3275 Reduce logging level of mutable secondary index logging
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/27722998
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/27722998
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/27722998
Branch: refs/heads/calcite
Commit: 27722998c35cbc14f8a6c1c1be1c0cc6b0f7769a
Parents: c0f72b5
Author: James Taylor <ja...@apache.org>
Authored: Tue Sep 13 22:52:42 2016 -0700
Committer: James Taylor <ja...@apache.org>
Committed: Tue Sep 13 22:52:42 2016 -0700
----------------------------------------------------------------------
.../phoenix/hbase/index/covered/NonTxIndexBuilder.java | 4 ++--
.../phoenix/hbase/index/covered/data/IndexMemStore.java | 10 +++++-----
.../hbase/index/covered/update/IndexUpdateManager.java | 4 ++--
3 files changed, 9 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/27722998/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/covered/NonTxIndexBuilder.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/covered/NonTxIndexBuilder.java b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/covered/NonTxIndexBuilder.java
index 10d164b..eb9dc96 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/covered/NonTxIndexBuilder.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/covered/NonTxIndexBuilder.java
@@ -70,8 +70,8 @@ public class NonTxIndexBuilder extends BaseIndexBuilder {
batchMutationAndAddUpdates(manager, state, mutation, indexMetaData);
- if (LOG.isDebugEnabled()) {
- LOG.debug("Found index updates for Mutation: " + mutation + "\n" + manager);
+ if (LOG.isTraceEnabled()) {
+ LOG.trace("Found index updates for Mutation: " + mutation + "\n" + manager);
}
return manager.toMap();
http://git-wip-us.apache.org/repos/asf/phoenix/blob/27722998/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/covered/data/IndexMemStore.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/covered/data/IndexMemStore.java b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/covered/data/IndexMemStore.java
index 5b68fa2..0fc9e14 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/covered/data/IndexMemStore.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/covered/data/IndexMemStore.java
@@ -113,8 +113,8 @@ public class IndexMemStore implements KeyValueStore {
@Override
public void add(KeyValue kv, boolean overwrite) {
- if (LOG.isDebugEnabled()) {
- LOG.info("Inserting: " + toString(kv));
+ if (LOG.isTraceEnabled()) {
+ LOG.trace("Inserting: " + toString(kv));
}
// if overwriting, we will always update
if (!overwrite) {
@@ -139,13 +139,13 @@ public class IndexMemStore implements KeyValueStore {
private String toString(KeyValue kv) {
return kv.toString() + "/value=" +
- Bytes.toString(kv.getValueArray(), kv.getValueOffset(), kv.getValueLength());
+ Bytes.toStringBinary(kv.getValueArray(), kv.getValueOffset(), kv.getValueLength());
}
@Override
public void rollback(KeyValue kv) {
- if (LOG.isDebugEnabled()) {
- LOG.debug("Rolling back: " + toString(kv));
+ if (LOG.isTraceEnabled()) {
+ LOG.trace("Rolling back: " + toString(kv));
}
// If the key is in the store, delete it
this.kvset.remove(kv);
http://git-wip-us.apache.org/repos/asf/phoenix/blob/27722998/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/covered/update/IndexUpdateManager.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/covered/update/IndexUpdateManager.java b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/covered/update/IndexUpdateManager.java
index 26f620f..a183186 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/covered/update/IndexUpdateManager.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/covered/update/IndexUpdateManager.java
@@ -209,7 +209,7 @@ public class IndexUpdateManager {
public String toString() {
StringBuffer sb = new StringBuffer("Pending Index Updates:\n");
for (Entry<ImmutableBytesPtr, Collection<Mutation>> entry : map.entrySet()) {
- String tableName = Bytes.toString(entry.getKey().get());
+ String tableName = Bytes.toStringBinary(entry.getKey().get());
sb.append(" Table: '" + tableName + "'\n");
for (Mutation m : entry.getValue()) {
sb.append("\t");
@@ -218,7 +218,7 @@ public class IndexUpdateManager {
}
sb.append(m.getClass().getSimpleName() + ":"
+ ((m instanceof Put) ? m.getTimeStamp() + " " : ""));
- sb.append(" row=" + Bytes.toString(m.getRow()));
+ sb.append(" row=" + Bytes.toStringBinary(m.getRow()));
sb.append("\n");
if (m.getFamilyCellMap().isEmpty()) {
sb.append("\t\t=== EMPTY ===\n");