Add additional logging during unique value read repair.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/b0c30593 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/b0c30593 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/b0c30593 Branch: refs/heads/master Commit: b0c30593a24d23fedbc16e033b91fb8cb1d999ea Parents: 8242878 Author: Michael Russo <[email protected]> Authored: Thu Jun 30 20:36:01 2016 -0700 Committer: Michael Russo <[email protected]> Committed: Thu Jun 30 20:36:01 2016 -0700 ---------------------------------------------------------------------- .../impl/UniqueValueSerializationStrategyImpl.java | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/b0c30593/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/serialization/impl/UniqueValueSerializationStrategyImpl.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/serialization/impl/UniqueValueSerializationStrategyImpl.java b/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/serialization/impl/UniqueValueSerializationStrategyImpl.java index 4456123..ce1f20e 100644 --- a/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/serialization/impl/UniqueValueSerializationStrategyImpl.java +++ b/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/serialization/impl/UniqueValueSerializationStrategyImpl.java @@ -335,7 +335,9 @@ public abstract class UniqueValueSerializationStrategyImpl<FieldKey, EntityKey> // do nothing, only versions can be newer and we're not worried about newer versions of same entity if (logger.isTraceEnabled()) { - logger.trace("Candidate unique value is equal to the current unique value"); + logger.trace("Current unique value [{}={}] entry has UUID [{}] equal to candidate UUID [{}]", + field.getName(), field.getValue().toString(), uniqueValue.getEntityId().getUuid(), + candidates.get(candidates.size() -1)); } // update candidate w/ latest version @@ -365,7 +367,8 @@ public abstract class UniqueValueSerializationStrategyImpl<FieldKey, EntityKey> candidates.clear(); if (logger.isTraceEnabled()) { - logger.trace("Updating candidate to entity id [{}] and entity version [{}]", + logger.trace("Updating candidate unique value [{}={}] to entity id [{}] and " + + "entity version [{}]", field.getName(), field.getValue().toString(), uniqueValue.getEntityId().getUuid(), uniqueValue.getEntityVersion()); } @@ -390,6 +393,10 @@ public abstract class UniqueValueSerializationStrategyImpl<FieldKey, EntityKey> } // take the last candidate ( should be the latest version) and add to the result set + if(logger.isTraceEnabled()){ + logger.trace("Adding unique value [{}] to response set.", + candidates.get(candidates.size() -1)); + } uniqueValueSet.addValue(candidates.get(candidates.size() -1)); }
