Răsfoiți Sursa

Added log lines to log (debug level) acknowledgements regarding index alias creation and index state change

Luca Cavanna 12 ani în urmă
părinte
comite
fc1d6670df

+ 2 - 1
src/main/java/org/elasticsearch/cluster/metadata/MetaDataIndexAliasesService.java

@@ -257,10 +257,11 @@ public class MetaDataIndexAliasesService extends AbstractComponent {
         @Override
         public void onAliasesUpdated(NodeAliasesUpdatedAction.NodeAliasesUpdatedResponse response) {
             if (version <= response.version()) {
-                logger.trace("Received NodeAliasesUpdatedResponse with version [{}] from [{}]", response.version(), response.nodeId());
+                logger.debug("Received NodeAliasesUpdatedResponse with version [{}] from [{}]", response.version(), response.nodeId());
                 if (countDown.decrementAndGet() == 0) {
                     aliasOperationPerformedAction.remove(this);
                     if (notified.compareAndSet(false, true)) {
+                        logger.debug("NodeAliasUpdated was acknowledged by all expected nodes, returning");
                         listener.onResponse(new Response(true));
                     }
                 }

+ 2 - 1
src/main/java/org/elasticsearch/cluster/metadata/MetaDataIndexStateService.java

@@ -288,10 +288,11 @@ public class MetaDataIndexStateService extends AbstractComponent {
         @Override
         public void onIndexStateUpdated(NodeIndicesStateUpdatedAction.NodeIndexStateUpdatedResponse response) {
             if (version <= response.version()) {
-                logger.trace("Received NodeIndexStateUpdatedResponse with version [{}] from [{}]", response.version(), response.nodeId());
+                logger.debug("Received NodeIndexStateUpdatedResponse with version [{}] from [{}]", response.version(), response.nodeId());
                 if (countDown.decrementAndGet() == 0) {
                     indicesStateUpdatedAction.remove(this);
                     if (notified.compareAndSet(false, true)) {
+                        logger.debug("NodeIndexStateUpdated was acknowledged by all expected nodes, returning");
                         listener.onResponse(new Response(true));
                     }
                 }