honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Increase timeout testFollowIndexWithConcurrentMappingChanges 

Fixes #59273
This commit is contained in:
Nhat Nguyen 2020-07-20 08:36:12 -04:00
parent 0031dea9cc
commit 0fe4d5df67
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
x-pack/plugin/ccr/src/internalClusterTest/java/org/elasticsearch/xpack/ccr/IndexFollowingIT.java
View File

@ -279,7 +279,9 @@ public class IndexFollowingIT extends CcrIntegTestCase {
leaderClient().admin().indices().prepareFlush("index1").setForce(true).get();
}
}
leaderClient().admin().indices().prepareFlush("index1").setForce(true).setWaitIfOngoing(true).get();
if (between(0, 100) < 20) {
leaderClient().admin().indices().prepareFlush("index1").setForce(false).setWaitIfOngoing(false).get();
}
}
});
thread.start();
@ -290,7 +292,7 @@ public class IndexFollowingIT extends CcrIntegTestCase {
ensureFollowerGreen("index2");
for (int i = 0; i < firstBatchNumDocs; i++) {
assertBusy(assertExpectedDocumentRunnable(i));
assertBusy(assertExpectedDocumentRunnable(i), 1, TimeUnit.MINUTES);
}
final int secondBatchNumDocs = randomIntBetween(2, 64);
@ -301,7 +303,7 @@ public class IndexFollowingIT extends CcrIntegTestCase {
}
for (int i = firstBatchNumDocs; i < firstBatchNumDocs + secondBatchNumDocs; i++) {
assertBusy(assertExpectedDocumentRunnable(i));
assertBusy(assertExpectedDocumentRunnable(i), 1, TimeUnit.MINUTES);
}
isRunning.set(false);