From ef58f86b0c7ec05bf084fc6b2f3c9afe87a47103 Mon Sep 17 00:00:00 2001 From: mohit10011999 Date: Mon, 10 Feb 2025 14:15:43 +0530 Subject: [PATCH] Adding fix for test knn index replication integ test failure (#1500) Signed-off-by: Mohit Kumar Co-authored by: Mohit Kumar (cherry picked from commit 1c019e6ee0c804ee4c5f2f0705318fb570f7b74c) --- .../org/opensearch/replication/BasicReplicationIT.kt | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/src/test/kotlin/org/opensearch/replication/BasicReplicationIT.kt b/src/test/kotlin/org/opensearch/replication/BasicReplicationIT.kt index c87fe4ec..c2b464a0 100644 --- a/src/test/kotlin/org/opensearch/replication/BasicReplicationIT.kt +++ b/src/test/kotlin/org/opensearch/replication/BasicReplicationIT.kt @@ -26,6 +26,10 @@ import org.opensearch.client.indices.CreateIndexRequest import org.opensearch.common.xcontent.XContentType import org.opensearch.common.CheckedRunnable import org.opensearch.test.OpenSearchTestCase.assertBusy +import org.opensearch.action.admin.indices.settings.get.GetSettingsRequest +import org.opensearch.action.admin.indices.settings.put.UpdateSettingsRequest +import org.opensearch.index.IndexSettings +import org.opensearch.common.settings.Settings import org.opensearch.client.indices.PutMappingRequest import org.junit.Assert import java.util.Locale @@ -94,11 +98,14 @@ class BasicReplicationIT : MultiClusterRestTestCase() { val leaderIndexName = randomAlphaOfLength(10).toLowerCase(Locale.ROOT) val followerIndexNameInitial = randomAlphaOfLength(10).toLowerCase(Locale.ROOT) val followerIndexName = randomAlphaOfLength(10).toLowerCase(Locale.ROOT) + val settings: Settings = Settings.builder() + .put("index.knn", true) + .build() val KNN_INDEX_MAPPING = "{\"properties\":{\"my_vector1\":{\"type\":\"knn_vector\",\"dimension\":2},\"my_vector2\":{\"type\":\"knn_vector\",\"dimension\":4}}}" // create knn-index on leader cluster try { val createIndexResponse = leaderClient.indices().create( - CreateIndexRequest(leaderIndexName) + CreateIndexRequest(leaderIndexName).settings(settings) .mapping(KNN_INDEX_MAPPING, XContentType.JSON), RequestOptions.DEFAULT ) assertThat(createIndexResponse.isAcknowledged).isTrue()