Revert "Update to plugins ISM API"

This reverts commit 3fd61af. Signed-off-by: Jürgen Walter <[email protected]>
opensearch-project · Sep 30, 2024 · bebe21a · bebe21a
1 parent cc72c27
commit bebe21a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/...grationTest/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSinkIT.java b/...grationTest/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSinkIT.java
@@ -1829,7 +1829,8 @@ private JsonNode getIndexSettings(final String index) throws IOException {
     }
 
     private String getIndexPolicyId(final String index) throws IOException {
-        final Request request = new Request(HttpMethod.GET, "/_plugins/_ism/explain/" + index);
+        // TODO: replace with new _opensearch API
+        final Request request = new Request(HttpMethod.GET, "/_opendistro/_ism/explain/" + index);
         final Response response = client.performRequest(request);
         final String responseBody = EntityUtils.toString(response.getEntity());
 

diff --git a/...in/java/org/opensearch/dataprepper/plugins/sink/opensearch/index/IsmPolicyManagement.java b/...in/java/org/opensearch/dataprepper/plugins/sink/opensearch/index/IsmPolicyManagement.java
@@ -44,7 +44,8 @@
 class IsmPolicyManagement implements IsmPolicyManagementStrategy {
     private static final Logger LOG = LoggerFactory.getLogger(IsmPolicyManagement.class);
 
-    private static final String POLICY_MANAGEMENT_ENDPOINT = "/_plugins/_ism/policies/";
+    // TODO: replace with new _opensearch API
+    private static final String POLICY_MANAGEMENT_ENDPOINT = "/_opendistro/_ism/policies/";
     public static final String DEFAULT_INDEX_SUFFIX = "-000001";
     private static final String POLICY_FILE_ROOT_KEY = "policy";
     private static final String POLICY_FILE_ISM_TEMPLATE_KEY = "ism_template";