|
@@ -14,16 +14,12 @@ import org.elasticsearch.common.settings.Settings;
|
|
|
import org.elasticsearch.index.Index;
|
|
|
import org.elasticsearch.indices.IndicesService;
|
|
|
import org.elasticsearch.indices.recovery.RecoveryState;
|
|
|
-import org.elasticsearch.plugins.Plugin;
|
|
|
-import org.elasticsearch.snapshots.mockstore.MockRepository;
|
|
|
import org.elasticsearch.test.ESIntegTestCase;
|
|
|
import org.elasticsearch.threadpool.ThreadPool;
|
|
|
import org.elasticsearch.xpack.searchablesnapshots.BaseSearchableSnapshotsIntegTestCase;
|
|
|
-import org.elasticsearch.xpack.searchablesnapshots.LocalStateSearchableSnapshots;
|
|
|
import org.elasticsearch.xpack.searchablesnapshots.SearchableSnapshots;
|
|
|
import org.hamcrest.Matchers;
|
|
|
|
|
|
-import java.util.Collection;
|
|
|
import java.util.List;
|
|
|
import java.util.concurrent.CountDownLatch;
|
|
|
import java.util.concurrent.CyclicBarrier;
|
|
@@ -36,11 +32,6 @@ import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertAcke
|
|
|
@ESIntegTestCase.ClusterScope(scope = ESIntegTestCase.Scope.TEST, numDataNodes = 0)
|
|
|
public class SearchableSnapshotsRelocationIntegTests extends BaseSearchableSnapshotsIntegTestCase {
|
|
|
|
|
|
- @Override
|
|
|
- protected Collection<Class<? extends Plugin>> nodePlugins() {
|
|
|
- return List.of(LocalStateSearchableSnapshots.class, MockRepository.Plugin.class);
|
|
|
- }
|
|
|
-
|
|
|
public void testRelocationWaitsForPreWarm() throws Exception {
|
|
|
internalCluster().startMasterOnlyNode();
|
|
|
final String firstDataNode = internalCluster().startDataOnlyNode();
|