diff --git a/build.gradle b/build.gradle index 6ed2c72a..9c48fbd3 100644 --- a/build.gradle +++ b/build.gradle @@ -6,7 +6,7 @@ import com.github.jengelman.gradle.plugins.shadow.ShadowPlugin buildscript { ext { - opensearch_version = System.getProperty("opensearch.version", "2.0.0-SNAPSHOT") + opensearch_version = System.getProperty("opensearch.version", "2.0.0-alpha1-SNAPSHOT") } repositories { diff --git a/spi/src/main/java/org/opensearch/jobscheduler/spi/utils/LockService.java b/spi/src/main/java/org/opensearch/jobscheduler/spi/utils/LockService.java index b2019e12..435135c2 100644 --- a/spi/src/main/java/org/opensearch/jobscheduler/spi/utils/LockService.java +++ b/spi/src/main/java/org/opensearch/jobscheduler/spi/utils/LockService.java @@ -41,11 +41,6 @@ public final class LockService { private static final Logger logger = LogManager.getLogger(LockService.class); - /** - * This should go away starting ES 7. We use "_doc" for future compatibility as described here: - * https://www.elastic.co/guide/en/elasticsearch/reference/6.x/removal-of-types.html#_schedule_for_removal_of_mapping_types - */ - private static final String MAPPING_TYPE = "_doc"; private static final String LOCK_INDEX_NAME = ".opendistro-job-scheduler-lock"; private final Client client; @@ -82,8 +77,7 @@ void createLockIndex(ActionListener listener) { if (lockIndexExist()) { listener.onResponse(true); } else { - final CreateIndexRequest request = new CreateIndexRequest(LOCK_INDEX_NAME) - .mapping(MAPPING_TYPE, lockMapping(), XContentType.JSON); + final CreateIndexRequest request = new CreateIndexRequest(LOCK_INDEX_NAME).mapping(lockMapping()); client.admin().indices().create(request, ActionListener.wrap( response -> listener.onResponse(response.isAcknowledged()), exception -> { diff --git a/src/test/java/org/opensearch/jobscheduler/sweeper/JobSweeperTests.java b/src/test/java/org/opensearch/jobscheduler/sweeper/JobSweeperTests.java index b2b0cf9d..56b5a939 100644 --- a/src/test/java/org/opensearch/jobscheduler/sweeper/JobSweeperTests.java +++ b/src/test/java/org/opensearch/jobscheduler/sweeper/JobSweeperTests.java @@ -283,7 +283,7 @@ private Engine.Index getIndexOperation() { "id_field", new BytesRef(docId.getBytes(Charset.defaultCharset()), 0, docId.getBytes(Charset.defaultCharset()).length) ); - ParsedDocument parsedDocument = new ParsedDocument(null, null, docId, "_doc", null, docs, source, null, null); + ParsedDocument parsedDocument = new ParsedDocument(null, null, docId, null, docs, source, null, null); return new Engine.Index(uid, primaryTerm, parsedDocument); } @@ -293,7 +293,7 @@ private Engine.Delete getDeleteOperation(String docId) { "id_field", new BytesRef(docId.getBytes(Charset.defaultCharset()), 0, docId.getBytes(Charset.defaultCharset()).length) ); - return new Engine.Delete("_doc", docId, uid, 1L); + return new Engine.Delete(docId, uid, 1L); } private BytesReference getTestJsonSource() {