You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by to...@apache.org on 2015/06/16 18:11:45 UTC
[06/10] incubator-usergrid git commit: add alias cache
add alias cache
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/81383252
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/81383252
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/81383252
Branch: refs/heads/two-dot-o-dev
Commit: 813832527aee02165d6eacd8890586f1b6d989c4
Parents: 98b5476
Author: Shawn Feldman <sf...@apache.org>
Authored: Mon Jun 15 16:03:27 2015 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Mon Jun 15 16:03:27 2015 -0600
----------------------------------------------------------------------
.../apache/usergrid/persistence/index/impl/EsEntityIndexImpl.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/81383252/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexImpl.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexImpl.java b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexImpl.java
index 051264f..e21c242 100644
--- a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexImpl.java
+++ b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsEntityIndexImpl.java
@@ -157,6 +157,7 @@ public class EsEntityIndexImpl implements EntityIndex,VersionedData {
final int numberOfShards = indexLocationStrategy.getNumberOfShards();
final int numberOfReplicas = indexLocationStrategy.getNumberOfReplicas();
+ aliasCache.invalidate(alias);
if (shouldInitialize()) {
addIndex( indexLocationStrategy.getIndexInitialName(), numberOfShards, numberOfReplicas, indexFig.getWriteConsistencyLevel() );
}