enable logs

pxsalehi · Sep 13, 2024 · f0f2845 · f0f2845
1 parent c1f09d3
commit f0f2845
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 5 deletions.
diff --git a/muted-tests.yml b/muted-tests.yml
@@ -49,9 +49,6 @@ tests:
   issue: https://github.com/elastic/elasticsearch/issues/110949
 - class: org.elasticsearch.multi_node.GlobalCheckpointSyncActionIT
   issue: https://github.com/elastic/elasticsearch/issues/111124
-- class: org.elasticsearch.cluster.PrevalidateShardPathIT
-  method: testCheckShards
-  issue: https://github.com/elastic/elasticsearch/issues/111134
 - class: org.elasticsearch.packaging.test.DockerTests
   method: test021InstallPlugin
   issue: https://github.com/elastic/elasticsearch/issues/110343

diff --git a/server/src/internalClusterTest/java/org/elasticsearch/cluster/PrevalidateShardPathIT.java b/server/src/internalClusterTest/java/org/elasticsearch/cluster/PrevalidateShardPathIT.java
@@ -42,10 +42,11 @@
 public class PrevalidateShardPathIT extends ESIntegTestCase {
 
     @TestIssueLogging(
-        value = "org.elasticsearch.cluster.service.MasterService:DEBUG, "
+        value = "org.elasticsearch.cluster.service.MasterService:DEBUG,"
             + "org.elasticsearch.indices.store.IndicesStore:TRACE,"
             + "org.elasticsearch.indices.cluster.IndicesClusterStateService:DEBUG,"
-            + "org.elasticsearch.indices.IndicesService:TRACE",
+            + "org.elasticsearch.indices.IndicesService:TRACE,"
+            + "org.elasticsearch.env.NodeEnvironment:TRACE",
         issueUrl = "https://github.com/elastic/elasticsearch/issues/104807"
     )
     public void testCheckShards() throws Exception {
@@ -135,5 +136,6 @@ public void testCheckShards() throws Exception {
                 throw e;
             }
         }, 30, TimeUnit.SECONDS);
+        logger.info("--> all done");
     }
 }
diff --git a/server/src/main/java/org/elasticsearch/indices/store/IndicesStore.java b/server/src/main/java/org/elasticsearch/indices/store/IndicesStore.java
@@ -235,6 +235,7 @@ private void deleteShardIfExistElseWhere(ClusterState state, IndexShardRoutingTa
             state.getVersion(),
             requests.size()
         );
+        logger.info("--> deleting if exists for {}", requests);
         for (Tuple<DiscoveryNode, ShardActiveRequest> request : requests) {
             logger.trace("{} sending shard active check to {}", request.v2().shardId, request.v1());
             transportService.sendRequest(request.v1(), ACTION_SHARD_EXISTS, request.v2(), responseHandler);
@@ -288,6 +289,7 @@ public void handleException(TransportException exp) {
         }
 
         private void allNodesResponded() {
+            logger.info("--> all nodes responses to the shard active request");
             if (activeCopies.get() != expectedActiveCopies) {
                 logger.trace(
                     "not deleting shard {}, expected {} active copies, but only {} found active copies",