honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-17 18:35:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

Adjust for long random timeout in acked indexing

Browse Source
This commit is contained in:
Jason Tedor 2016-03-29 12:09:48 -04:00
parent 649bcdc4eb
commit 27448dc3d0
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
core/src/test/java/org/elasticsearch/discovery/DiscoveryWithServiceDisruptionsIT.java
View File

@ -444,7 +444,8 @@ public class DiscoveryWithServiceDisruptionsIT extends ESIntegTestCase {
+ "indices.recovery:TRACE,indices.cluster:TRACE")
public void testAckedIndexing() throws Exception {
final String timeout = !(TEST_NIGHTLY && rarely()) ? "1s" : "5s";
final int seconds = !(TEST_NIGHTLY && rarely()) ? 1 : 5;
final String timeout = seconds + "s";
// TODO: add node count randomizaion
final List<String> nodes = startCluster(3);
@ -534,7 +535,7 @@ public class DiscoveryWithServiceDisruptionsIT extends ESIntegTestCase {
semaphore.release(docsPerIndexer);
}
logger.info("waiting for indexing requests to complete");
assertTrue(countDownLatchRef.get().await(docsPerIndexer * 1000 + 2000, TimeUnit.MILLISECONDS));
assertTrue(countDownLatchRef.get().await(docsPerIndexer * seconds * 1000 + 2000, TimeUnit.MILLISECONDS));
logger.info("stopping disruption");
disruptionScheme.stopDisrupting();