|
|
@@ -78,7 +78,7 @@ public class AutoFollowIT extends CcrIntegTestCase {
|
|
|
createLeaderIndex("metrics-201901", leaderIndexSettings);
|
|
|
|
|
|
createLeaderIndex("logs-201901", leaderIndexSettings);
|
|
|
- assertBusy(() -> {
|
|
|
+ assertLongBusy(() -> {
|
|
|
assertTrue(ESIntegTestCase.indexExists("copy-logs-201901", followerClient()));
|
|
|
});
|
|
|
createLeaderIndex("transactions-201901", leaderIndexSettings);
|
|
|
@@ -252,7 +252,7 @@ public class AutoFollowIT extends CcrIntegTestCase {
|
|
|
assertTrue(followerClient().execute(PutAutoFollowPatternAction.INSTANCE, request).actionGet().isAcknowledged());
|
|
|
|
|
|
createLeaderIndex("logs-201901", leaderIndexSettings);
|
|
|
- assertBusy(() -> {
|
|
|
+ assertLongBusy(() -> {
|
|
|
FollowInfoAction.Request followInfoRequest = new FollowInfoAction.Request();
|
|
|
followInfoRequest.setFollowerIndices("copy-logs-201901");
|
|
|
FollowInfoAction.Response followInfoResponse;
|