fix test
This commit is contained in:
parent
2b03a03c0c
commit
3a9c2bd639
|
@ -19,20 +19,28 @@
|
||||||
package org.elasticsearch.indices;
|
package org.elasticsearch.indices;
|
||||||
|
|
||||||
import org.elasticsearch.action.admin.indices.seal.SealIndicesResponse;
|
import org.elasticsearch.action.admin.indices.seal.SealIndicesResponse;
|
||||||
|
import org.elasticsearch.common.settings.ImmutableSettings;
|
||||||
import org.elasticsearch.test.ElasticsearchIntegrationTest;
|
import org.elasticsearch.test.ElasticsearchIntegrationTest;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
|
|
||||||
|
import static java.lang.Thread.sleep;
|
||||||
import static org.hamcrest.Matchers.equalTo;
|
import static org.hamcrest.Matchers.equalTo;
|
||||||
|
|
||||||
@ElasticsearchIntegrationTest.ClusterScope(scope = ElasticsearchIntegrationTest.Scope.SUITE, numDataNodes = 1)
|
@ElasticsearchIntegrationTest.ClusterScope(scope = ElasticsearchIntegrationTest.Scope.TEST, numDataNodes = 0)
|
||||||
public class SealTests extends ElasticsearchIntegrationTest {
|
public class SealTests extends ElasticsearchIntegrationTest {
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void testUnallocatedShardsDoesNotHang() throws InterruptedException {
|
public void testUnallocatedShardsDoesNotHang() throws InterruptedException {
|
||||||
// create an index but because no data nodes are available no shards will be allocated
|
ImmutableSettings.Builder settingsBuilder = ImmutableSettings.builder()
|
||||||
|
.put("node.data", false)
|
||||||
|
.put("node.master", true)
|
||||||
|
.put("path.data", createTempDir().toString());
|
||||||
|
internalCluster().startNode(settingsBuilder.build());
|
||||||
|
// create an index but because no data nodes are available no shards will be allocated
|
||||||
createIndex("test");
|
createIndex("test");
|
||||||
// this should not hang but instead immediately return with empty result set
|
// this should not hang but instead immediately return with empty result set
|
||||||
SealIndicesResponse sealIndicesResponse = client().admin().indices().prepareSealIndices("test").get();
|
SealIndicesResponse sealIndicesResponse = client().admin().indices().prepareSealIndices("test").get();
|
||||||
|
// just to make sure the test actually tests the right thing
|
||||||
assertThat(sealIndicesResponse.results().size(), equalTo(0));
|
assertThat(sealIndicesResponse.results().size(), equalTo(0));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue