@@ -548,7 +548,7 @@ public void onNodeDisconnected(DiscoveryNode node) {
548
548
549
549
//give transport service enough time to realize that the node is down, and to notify the connection listeners
550
550
//so that RemoteClusterConnection is left with no connected nodes, hence it will retry connecting next
551
- assertTrue (disconnectedLatch .await (5 , TimeUnit .SECONDS ));
551
+ assertTrue (disconnectedLatch .await (30 , TimeUnit .SECONDS ));
552
552
553
553
service .clearAllRules ();
554
554
if (randomBoolean ()) {
@@ -610,7 +610,7 @@ public void testCollectSearchShards() throws Exception {
610
610
TransportSearchAction .collectSearchShards (IndicesOptions .lenientExpandOpen (), null , null , skippedClusters ,
611
611
remoteIndicesByCluster , remoteClusterService , threadPool ,
612
612
new LatchedActionListener <>(ActionListener .wrap (response ::set , e -> fail ("no failures expected" )), latch ));
613
- awaitLatch (latch , 5 , TimeUnit .SECONDS );
613
+ awaitLatch (latch , 30 , TimeUnit .SECONDS );
614
614
assertEquals (0 , skippedClusters .get ());
615
615
assertNotNull (response .get ());
616
616
Map <String , ClusterSearchShardsResponse > map = response .get ();
@@ -629,7 +629,7 @@ public void testCollectSearchShards() throws Exception {
629
629
TransportSearchAction .collectSearchShards (IndicesOptions .lenientExpandOpen (), "index_not_found" , null , skippedClusters ,
630
630
remoteIndicesByCluster , remoteClusterService , threadPool ,
631
631
new LatchedActionListener <>(ActionListener .wrap (r -> fail ("no response expected" ), failure ::set ), latch ));
632
- awaitLatch (latch , 5 , TimeUnit .SECONDS );
632
+ awaitLatch (latch , 30 , TimeUnit .SECONDS );
633
633
assertEquals (0 , skippedClusters .get ());
634
634
assertNotNull (failure .get ());
635
635
assertThat (failure .get (), instanceOf (RemoteTransportException .class ));
@@ -667,7 +667,7 @@ public void onNodeDisconnected(DiscoveryNode node) {
667
667
TransportSearchAction .collectSearchShards (IndicesOptions .lenientExpandOpen (), null , null , skippedClusters ,
668
668
remoteIndicesByCluster , remoteClusterService , threadPool ,
669
669
new LatchedActionListener <>(ActionListener .wrap (r -> fail ("no response expected" ), failure ::set ), latch ));
670
- awaitLatch (latch , 5 , TimeUnit .SECONDS );
670
+ awaitLatch (latch , 30 , TimeUnit .SECONDS );
671
671
assertEquals (0 , skippedClusters .get ());
672
672
assertNotNull (failure .get ());
673
673
assertThat (failure .get (), instanceOf (RemoteTransportException .class ));
@@ -687,7 +687,7 @@ public void onNodeDisconnected(DiscoveryNode node) {
687
687
TransportSearchAction .collectSearchShards (IndicesOptions .lenientExpandOpen (), null , null , skippedClusters ,
688
688
remoteIndicesByCluster , remoteClusterService , threadPool ,
689
689
new LatchedActionListener <>(ActionListener .wrap (response ::set , e -> fail ("no failures expected" )), latch ));
690
- awaitLatch (latch , 5 , TimeUnit .SECONDS );
690
+ awaitLatch (latch , 30 , TimeUnit .SECONDS );
691
691
assertNotNull (response .get ());
692
692
Map <String , ClusterSearchShardsResponse > map = response .get ();
693
693
assertEquals (numClusters - disconnectedNodesIndices .size (), map .size ());
@@ -704,7 +704,7 @@ public void onNodeDisconnected(DiscoveryNode node) {
704
704
705
705
//give transport service enough time to realize that the node is down, and to notify the connection listeners
706
706
//so that RemoteClusterConnection is left with no connected nodes, hence it will retry connecting next
707
- assertTrue (disconnectedLatch .await (5 , TimeUnit .SECONDS ));
707
+ assertTrue (disconnectedLatch .await (30 , TimeUnit .SECONDS ));
708
708
709
709
service .clearAllRules ();
710
710
if (randomBoolean ()) {
@@ -722,7 +722,7 @@ public void onNodeDisconnected(DiscoveryNode node) {
722
722
TransportSearchAction .collectSearchShards (IndicesOptions .lenientExpandOpen (), null , null , skippedClusters ,
723
723
remoteIndicesByCluster , remoteClusterService , threadPool ,
724
724
new LatchedActionListener <>(ActionListener .wrap (response ::set , e -> fail ("no failures expected" )), latch ));
725
- awaitLatch (latch , 5 , TimeUnit .SECONDS );
725
+ awaitLatch (latch , 30 , TimeUnit .SECONDS );
726
726
assertEquals (0 , skippedClusters .get ());
727
727
assertNotNull (response .get ());
728
728
Map <String , ClusterSearchShardsResponse > map = response .get ();
0 commit comments