test

Signed-off-by: kkewwei <[email protected]>
opensearch-project · Sep 26, 2024 · dc78714 · dc78714
1 parent 5888867
commit dc78714
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/server/src/internalClusterTest/java/org/opensearch/gateway/RecoveryFromGatewayIT.java b/server/src/internalClusterTest/java/org/opensearch/gateway/RecoveryFromGatewayIT.java
@@ -1382,6 +1382,7 @@ public void testShardStoreFetchMultiNodeMultiIndexesUsingBatchAction() throws Ex
         String indexName1 = "test1";
         String indexName2 = "test2";
         DiscoveryNode[] nodes = getDiscoveryNodes();
+        System.out.println();
         TransportNodesListShardStoreMetadataBatch.NodesStoreFilesMetadataBatch response = prepareAndSendRequest(
             new String[] { indexName1, indexName2 },
             nodes
@@ -1392,6 +1393,7 @@ public void testShardStoreFetchMultiNodeMultiIndexesUsingBatchAction() throws Ex
             ShardRouting[] shardRoutings = clusterSearchShardsGroup.getShards();
             assertEquals(2, shardRoutings.length);
             for (ShardRouting shardRouting : shardRoutings) {
+                System.out.println("----------------" + shardRouting.shortSummary());
                 TransportNodesListShardStoreMetadataBatch.NodeStoreFilesMetadata nodeStoreFilesMetadata = response.getNodesMap()
                     .get(shardRouting.currentNodeId())
                     .getNodeStoreFilesMetadataBatch()
@@ -1532,8 +1534,11 @@ private void assertNodeStoreFilesMetadataSuccessCase(
         assertNull(nodeStoreFilesMetadata.getStoreFileFetchException());
         TransportNodesListShardStoreMetadataHelper.StoreFilesMetadata storeFileMetadata = nodeStoreFilesMetadata.storeFilesMetadata();
         assertFalse(storeFileMetadata.isEmpty());
+        System.out.println("----------" + storeFileMetadata);
         assertEquals(shardId, storeFileMetadata.shardId());
         assertNotNull(storeFileMetadata.peerRecoveryRetentionLeases());
+        System.out.println("----------" + storeFileMetadata.peerRecoveryRetentionLeases());
+
     }
 
     private void assertNodeGatewayStartedShardsHappyCase(GatewayStartedShard gatewayStartedShard) {