summaryrefslogtreecommitdiff
path: root/core/src/test/java/org/elasticsearch/versioning
diff options
context:
space:
mode:
authorLee Hinman <lee@writequit.org>2016-09-07 11:00:09 -0600
committerLee Hinman <lee@writequit.org>2016-09-08 15:29:47 -0600
commit49695af2ac8dd52d461b10a12b9c826e3f6691e7 (patch)
tree25c800fc993894702d034da08812e523db0e6bdd /core/src/test/java/org/elasticsearch/versioning
parent3713d7994de030dda5ef6aadd87bb44bb8308ee8 (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.java30
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");