You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sf...@apache.org on 2015/07/07 17:50:34 UTC
[2/2] incubator-usergrid git commit: add logging to shard allocation
add logging to shard allocation
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/e3724d7f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/e3724d7f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/e3724d7f
Branch: refs/heads/two-dot-o-dev
Commit: e3724d7fa21eee16c487222f120ce415981fc0ee
Parents: bc03cdb
Author: Shawn Feldman <sf...@apache.org>
Authored: Tue Jul 7 09:50:26 2015 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Tue Jul 7 09:50:26 2015 -0600
----------------------------------------------------------------------
.../serialization/impl/shard/impl/NodeShardAllocationImpl.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/e3724d7f/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/serialization/impl/shard/impl/NodeShardAllocationImpl.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/serialization/impl/shard/impl/NodeShardAllocationImpl.java b/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/serialization/impl/shard/impl/NodeShardAllocationImpl.java
index ad64338..7a7fb3f 100644
--- a/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/serialization/impl/shard/impl/NodeShardAllocationImpl.java
+++ b/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/serialization/impl/shard/impl/NodeShardAllocationImpl.java
@@ -173,6 +173,10 @@ public class NodeShardAllocationImpl implements NodeShardAllocation {
return false;
}
+ if(LOG.isDebugEnabled()){
+ LOG.debug("Count of {} has exceeded shard config of {} will begin compacting", count, shardSize);
+ }
+
/**
* We want to allocate a new shard as close to the max value as possible. This way if we're filling up a shard rapidly, we split it near the head of the values.
* Further checks to this group will result in more splits, similar to creating a tree type structure and splitting each node.