diff --git a/modules/reindex/src/test/java/org/elasticsearch/index/reindex/CancelTests.java b/modules/reindex/src/test/java/org/elasticsearch/index/reindex/CancelTests.java index 59093252d7e05..ed2c1c53f9b83 100644 --- a/modules/reindex/src/test/java/org/elasticsearch/index/reindex/CancelTests.java +++ b/modules/reindex/src/test/java/org/elasticsearch/index/reindex/CancelTests.java @@ -29,9 +29,10 @@ import org.elasticsearch.index.engine.Engine; import org.elasticsearch.index.engine.Engine.Operation.Origin; import org.elasticsearch.index.shard.IndexingOperationListener; +import org.elasticsearch.ingest.IngestTestPlugin; import org.elasticsearch.plugins.Plugin; import org.elasticsearch.tasks.TaskInfo; -import org.elasticsearch.ingest.IngestTestPlugin; +import org.elasticsearch.test.ESIntegTestCase.ClusterScope; import org.junit.BeforeClass; import java.util.ArrayList; @@ -43,6 +44,7 @@ import java.util.stream.IntStream; import static org.elasticsearch.index.query.QueryBuilders.termQuery; +import static org.elasticsearch.test.ESIntegTestCase.Scope.SUITE; import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertAcked; import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertHitCount; import static org.hamcrest.Matchers.empty; @@ -55,6 +57,7 @@ * different cancellation places - that is the responsibility of {@link AsyncBulkByScrollActionTests} which have more precise control to * simulate failures but do not exercise important portion of the stack like transport and task management. */ +@ClusterScope(scope = SUITE, transportClientRatio = 0) public class CancelTests extends ReindexTestCase { protected static final String INDEX = "reindex-cancel-index";