Move shard logging statement to TRACE level.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/69cfbbd1 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/69cfbbd1 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/69cfbbd1 Branch: refs/heads/master Commit: 69cfbbd156e06be4dd38571a8fa76147ac364e54 Parents: 058d33a Author: Michael Russo <[email protected]> Authored: Wed Aug 31 21:45:42 2016 -0700 Committer: Michael Russo <[email protected]> Committed: Wed Aug 31 21:45:42 2016 -0700 ---------------------------------------------------------------------- .../impl/shard/impl/ShardedEdgeSerializationImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/69cfbbd1/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/serialization/impl/shard/impl/ShardedEdgeSerializationImpl.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/serialization/impl/shard/impl/ShardedEdgeSerializationImpl.java b/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/serialization/impl/shard/impl/ShardedEdgeSerializationImpl.java index 822f238..c518e75 100644 --- a/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/serialization/impl/shard/impl/ShardedEdgeSerializationImpl.java +++ b/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/serialization/impl/shard/impl/ShardedEdgeSerializationImpl.java @@ -729,12 +729,12 @@ public class ShardedEdgeSerializationImpl implements ShardedEdgeSerialization { final R rowKey = getRowKey( shard ); writeEdge( batch, columnFamily, scope, rowKey, column, shard, isDeleted ); - if(getDirectedEdge() instanceof DirectedEdge){ + if(logger.isTraceEnabled() && getDirectedEdge() instanceof DirectedEdge){ DirectedEdge directedEdge = (DirectedEdge) getDirectedEdge(); if( shard != null && shard.getShardEnd().isPresent() && directedEdge.timestamp > shard.getShardEnd().get().timestamp){ - logger.warn("Writing edge past shard end for edge: {}, shard: {}", directedEdge, shard ); + logger.trace("Writing edge past shard end for edge: {}, shard: {}", directedEdge, shard ); } }
