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

Tests: Mark the entire RiverTests suite as AwaitsFix.

This commit is contained in:
Adrien Grand 2015-04-27 09:27:17 +02:00
parent 061a010453
commit 8d30c9a392
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/test/java/org/elasticsearch/river/RiverTests.java
View File

@ -20,6 +20,8 @@
package org.elasticsearch.river; package org.elasticsearch.river;
import com.google.common.base.Predicate; import com.google.common.base.Predicate;
import org.apache.lucene.util.LuceneTestCase.AwaitsFix;
import org.elasticsearch.action.get.GetResponse; import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.get.MultiGetItemResponse; import org.elasticsearch.action.get.MultiGetItemResponse;
import org.elasticsearch.action.get.MultiGetRequestBuilder; import org.elasticsearch.action.get.MultiGetRequestBuilder;
@ -29,15 +31,16 @@ import org.elasticsearch.common.xcontent.json.JsonXContent;
import org.elasticsearch.index.mapper.MapperService; import org.elasticsearch.index.mapper.MapperService;
import org.elasticsearch.river.dummy.DummyRiverModule; import org.elasticsearch.river.dummy.DummyRiverModule;
import org.elasticsearch.test.ElasticsearchIntegrationTest; import org.elasticsearch.test.ElasticsearchIntegrationTest;
import org.elasticsearch.test.ElasticsearchIntegrationTest.ClusterScope;
import org.junit.Test; import org.junit.Test;
import java.util.concurrent.CountDownLatch; import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import static org.elasticsearch.test.ElasticsearchIntegrationTest.ClusterScope;
import static org.hamcrest.Matchers.equalTo; import static org.hamcrest.Matchers.equalTo;
@ClusterScope(scope = ElasticsearchIntegrationTest.Scope.SUITE) @ClusterScope(scope = ElasticsearchIntegrationTest.Scope.SUITE)
@AwaitsFix(bugUrl="occasionally fails apparently due to synchronous mappings updates")
public class RiverTests extends ElasticsearchIntegrationTest { public class RiverTests extends ElasticsearchIntegrationTest {
@Test @Test
@ -46,7 +49,6 @@ public class RiverTests extends ElasticsearchIntegrationTest {
} }
@Test @Test
@AwaitsFix(bugUrl="occasionally fails apparently due to synchronous mappings updates")
public void testMultipleRiversStart() throws Exception { public void testMultipleRiversStart() throws Exception {
int nbRivers = between(2,10); int nbRivers = between(2,10);
logger.info("--> testing with {} rivers...", nbRivers); logger.info("--> testing with {} rivers...", nbRivers);