Increase await timeouts in RemoteClusterServiceTests
Closes
@@ -741,7 +741,7 @@ public class RemoteClusterServiceTests extends ESTestCase {
AtomicReference<Exception> failure = new AtomicReference<>();
remoteClusterService.collectSearchShards(IndicesOptions.lenientExpandOpen(), null, null, remoteIndicesByCluster,
new LatchedActionListener<>(ActionListener.wrap(response::set, failure::set), latch));
- assertTrue(latch.await(1, TimeUnit.SECONDS));
+ assertTrue(latch.await(5, TimeUnit.SECONDS));
assertNull(failure.get());
assertNotNull(response.get());
Map<String, ClusterSearchShardsResponse> map = response.get();
@@ -760,7 +760,7 @@ public class RemoteClusterServiceTests extends ESTestCase {
remoteClusterService.collectSearchShards(IndicesOptions.lenientExpandOpen(), "index_not_found",
null, remoteIndicesByCluster,
new LatchedActionListener<>(ActionListener.wrap(response::set, failure::set), latch));
- assertTrue(latch.await(2, TimeUnit.SECONDS));
+ assertTrue(latch.await(5, TimeUnit.SECONDS));
assertNull(response.get());
assertNotNull(failure.get());
assertThat(failure.get(), instanceOf(RemoteTransportException.class));
@@ -799,7 +799,7 @@ public class RemoteClusterServiceTests extends ESTestCase {
AtomicReference<Exception> failure = new AtomicReference<>();
remoteClusterService.collectSearchShards(IndicesOptions.lenientExpandOpen(), null, null, remoteIndicesByCluster,
new LatchedActionListener<>(ActionListener.wrap(response::set, failure::set), latch));
- assertTrue(latch.await(1, TimeUnit.SECONDS));
+ assertTrue(latch.await(5, TimeUnit.SECONDS));
assertNull(response.get());
assertNotNull(failure.get());
assertThat(failure.get(), instanceOf(RemoteTransportException.class));
@@ -817,7 +817,7 @@ public class RemoteClusterServiceTests extends ESTestCase {
AtomicReference<Exception> failure = new AtomicReference<>();
remoteClusterService.collectSearchShards(IndicesOptions.lenientExpandOpen(), null, null, remoteIndicesByCluster,
new LatchedActionListener<>(ActionListener.wrap(response::set, failure::set), latch));
- assertTrue(latch.await(1, TimeUnit.SECONDS));
+ assertTrue(latch.await(5, TimeUnit.SECONDS));
assertNull(failure.get());
assertNotNull(response.get());
Map<String, ClusterSearchShardsResponse> map = response.get();
@@ -836,7 +836,7 @@ public class RemoteClusterServiceTests extends ESTestCase {
//give transport service enough time to realize that the node is down, and to notify the connection listeners
//so that RemoteClusterConnection is left with no connected nodes, hence it will retry connecting next
- assertTrue(disconnectedLatch.await(1, TimeUnit.SECONDS));
+ assertTrue(disconnectedLatch.await(5, TimeUnit.SECONDS));
service.clearAllRules();
if (randomBoolean()) {
@@ -853,7 +853,7 @@ public class RemoteClusterServiceTests extends ESTestCase {
AtomicReference<Exception> failure = new AtomicReference<>();
remoteClusterService.collectSearchShards(IndicesOptions.lenientExpandOpen(), null, null, remoteIndicesByCluster,
new LatchedActionListener<>(ActionListener.wrap(response::set, failure::set), latch));
- assertTrue(latch.await(1, TimeUnit.SECONDS));
+ assertTrue(latch.await(5, TimeUnit.SECONDS));
assertNull(failure.get());
assertNotNull(response.get());
Map<String, ClusterSearchShardsResponse> map = response.get();
@@ -862,7 +862,7 @@ public class RemoteClusterServiceTests extends ESTestCase {
String clusterAlias = "remote" + i;
assertTrue(map.containsKey(clusterAlias));
ClusterSearchShardsResponse shardsResponse = map.get(clusterAlias);
- assertTrue(shardsResponse != ClusterSearchShardsResponse.EMPTY);
+ assertNotSame(ClusterSearchShardsResponse.EMPTY, shardsResponse);
}
}
assertEquals(0, service.getConnectionManager().size());
