diff options
author | Lee Hinman <lee@writequit.org> | 2016-09-07 11:00:09 -0600 |
---|---|---|
committer | Lee Hinman <lee@writequit.org> | 2016-09-08 15:29:47 -0600 |
commit | 49695af2ac8dd52d461b10a12b9c826e3f6691e7 (patch) | |
tree | 25c800fc993894702d034da08812e523db0e6bdd /core/src/test/java/org/elasticsearch/versioning | |
parent | 3713d7994de030dda5ef6aadd87bb44bb8308ee8 (diff) |
Remove FORCE version_type
This was an error-prone version type that allowed overriding previous
version semantics. It could cause primaries and replicas to be out of
sync however, so it has been removed.
Resolves #19769
Diffstat (limited to 'core/src/test/java/org/elasticsearch/versioning')
-rw-r--r-- | core/src/test/java/org/elasticsearch/versioning/SimpleVersioningIT.java | 30 |
1 files changed, 0 insertions, 30 deletions
diff --git a/core/src/test/java/org/elasticsearch/versioning/SimpleVersioningIT.java b/core/src/test/java/org/elasticsearch/versioning/SimpleVersioningIT.java index 67e7d528e5..b80c5bd8e2 100644 --- a/core/src/test/java/org/elasticsearch/versioning/SimpleVersioningIT.java +++ b/core/src/test/java/org/elasticsearch/versioning/SimpleVersioningIT.java @@ -72,36 +72,6 @@ public class SimpleVersioningIT extends ESIntegTestCase { assertThat(indexResponse.getVersion(), equalTo(18L)); } - public void testForce() throws Exception { - createIndex("test"); - ensureGreen("test"); // we are testing force here which doesn't work if we are recovering at the same time - zzzzz... - IndexResponse indexResponse = client().prepareIndex("test", "type", "1").setSource("field1", "value1_1").setVersion(12).setVersionType(VersionType.FORCE).get(); - assertThat(indexResponse.getVersion(), equalTo(12L)); - - indexResponse = client().prepareIndex("test", "type", "1").setSource("field1", "value1_2").setVersion(12).setVersionType(VersionType.FORCE).get(); - assertThat(indexResponse.getVersion(), equalTo(12L)); - - indexResponse = client().prepareIndex("test", "type", "1").setSource("field1", "value1_2").setVersion(14).setVersionType(VersionType.FORCE).get(); - assertThat(indexResponse.getVersion(), equalTo(14L)); - - indexResponse = client().prepareIndex("test", "type", "1").setSource("field1", "value1_1").setVersion(13).setVersionType(VersionType.FORCE).get(); - assertThat(indexResponse.getVersion(), equalTo(13L)); - - client().admin().indices().prepareRefresh().execute().actionGet(); - if (randomBoolean()) { - refresh(); - } - for (int i = 0; i < 10; i++) { - assertThat(client().prepareGet("test", "type", "1").get().getVersion(), equalTo(13L)); - } - - // deleting with a lower version works. - long v = randomIntBetween(12, 14); - DeleteResponse deleteResponse = client().prepareDelete("test", "type", "1").setVersion(v).setVersionType(VersionType.FORCE).get(); - assertEquals(DocWriteResponse.Result.DELETED, deleteResponse.getResult()); - assertThat(deleteResponse.getVersion(), equalTo(v)); - } - public void testExternalGTE() throws Exception { createIndex("test"); |