Increase timeout in PrimaryFollowerAllocationIT

A slow CI can take more than 10 seconds to relocate shards on the follower.
elastic · Aug 13, 2020 · 74a1519 · 74a1519
1 parent 7ab5b43
commit 74a1519
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/...src/internalClusterTest/java/org/elasticsearch/xpack/ccr/PrimaryFollowerAllocationIT.java b/...src/internalClusterTest/java/org/elasticsearch/xpack/ccr/PrimaryFollowerAllocationIT.java
@@ -18,6 +18,7 @@
 import org.elasticsearch.xpack.core.ccr.action.PutFollowAction;
 
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 
 import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertAcked;
 import static org.hamcrest.Matchers.in;
@@ -59,10 +60,10 @@ public void testAllocateFollowerPrimaryToNodesWithRemoteClusterClientRole() thro
                 for (ShardRouting shard : shardRoutingTable) {
                     assertNotNull(shard.currentNodeId());
                     final DiscoveryNode assignedNode = state.nodes().get(shard.currentNodeId());
-                    assertThat(assignedNode.getName(), in(dataOnlyNodes));
+                    assertThat(shardRoutingTable.toString(), assignedNode.getName(), in(dataOnlyNodes));
                 }
             }
-        });
+        }, 30, TimeUnit.SECONDS);
         assertIndexFullyReplicatedToFollower(leaderIndex, followerIndex);
         // Follower primaries can be recovered from the existing copies on nodes without the remote cluster client role
         getFollowerCluster().fullRestart();
@@ -73,10 +74,10 @@ public void testAllocateFollowerPrimaryToNodesWithRemoteClusterClientRole() thro
                 for (ShardRouting shard : shardRoutingTable) {
                     assertNotNull(shard.currentNodeId());
                     final DiscoveryNode assignedNode = state.nodes().get(shard.currentNodeId());
-                    assertThat(assignedNode.getName(), in(dataOnlyNodes));
+                    assertThat(shardRoutingTable.toString(), assignedNode.getName(), in(dataOnlyNodes));
                 }
             }
-        });
+        }, 30, TimeUnit.SECONDS);
         int moreDocs = between(0, 20);
         for (int i = 0; i < moreDocs; i++) {
             leaderClient().prepareIndex(leaderIndex, "_doc").setSource("f", i).get();