From 27267362124a720e13460e25ccca653c46b211a1 Mon Sep 17 00:00:00 2001 From: David Kyle Date: Fri, 1 Mar 2019 16:58:35 +0000 Subject: [PATCH] Remove type from DeleteExpiredDataIT --- .../xpack/ml/integration/DeleteExpiredDataIT.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/x-pack/plugin/ml/qa/native-multi-node-tests/src/test/java/org/elasticsearch/xpack/ml/integration/DeleteExpiredDataIT.java b/x-pack/plugin/ml/qa/native-multi-node-tests/src/test/java/org/elasticsearch/xpack/ml/integration/DeleteExpiredDataIT.java index 398eb6c230f02..a4ce7756b3c7d 100644 --- a/x-pack/plugin/ml/qa/native-multi-node-tests/src/test/java/org/elasticsearch/xpack/ml/integration/DeleteExpiredDataIT.java +++ b/x-pack/plugin/ml/qa/native-multi-node-tests/src/test/java/org/elasticsearch/xpack/ml/integration/DeleteExpiredDataIT.java @@ -49,7 +49,7 @@ public class DeleteExpiredDataIT extends MlNativeAutodetectIntegTestCase { private static final String DATA_INDEX = "delete-expired-data-test-data"; - private static final String DATA_TYPE = "doc"; + private static final String DATA_TYPE = "_doc"; @Before public void setUpData() throws IOException { @@ -68,7 +68,7 @@ public void setUpData() throws IOException { long timestamp = nowMillis - TimeValue.timeValueHours(totalBuckets - bucket).getMillis(); int bucketRate = bucket == anomalousBucket ? anomalousRate : normalRate; for (int point = 0; point < bucketRate; point++) { - IndexRequest indexRequest = new IndexRequest(DATA_INDEX, DATA_TYPE); + IndexRequest indexRequest = new IndexRequest(DATA_INDEX); indexRequest.source("time", timestamp); bulkRequestBuilder.add(indexRequest); } @@ -97,7 +97,7 @@ public void testDeleteExpiredData() throws Exception { bulkRequestBuilder.setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE); for (int i = 0; i < 10010; i++) { String docId = "non_existing_job_" + randomFrom("model_state_1234567#" + i, "quantiles", "categorizer_state#" + i); - IndexRequest indexRequest = new IndexRequest(AnomalyDetectorsIndex.jobStateIndexWriteAlias(), "doc", docId); + IndexRequest indexRequest = new IndexRequest(AnomalyDetectorsIndex.jobStateIndexWriteAlias()).id(docId); indexRequest.source(Collections.emptyMap()); bulkRequestBuilder.add(indexRequest); }