From 4d60adf8fad464100b711d539db5da6b49ad687e Mon Sep 17 00:00:00 2001 From: Hai Yan <8153134+oeyh@users.noreply.github.com> Date: Fri, 8 Mar 2024 10:02:50 -0600 Subject: [PATCH] Set up serverless network policy before setting up index (#4250) Signed-off-by: Hai Yan --- .../plugins/sink/opensearch/OpenSearchSink.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSink.java b/data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSink.java index f2d3f66619..8f20daa561 100644 --- a/data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSink.java +++ b/data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSink.java @@ -228,6 +228,10 @@ private void doInitializeInternal() throws IOException { .add(pluginSetting.getName()).toString()); dlqWriter = potentialDlq.isPresent() ? potentialDlq.get() : null; } + + // Attempt to update the serverless network policy if required argument are given. + maybeUpdateServerlessNetworkPolicy(); + indexManager.setupIndex(); final Boolean requireAlias = indexManager.isIndexAlias(configuredIndexAlias); @@ -257,9 +261,6 @@ private void doInitializeInternal() throws IOException { bulkRequestSupplier, pluginSetting); - // Attempt to update the serverless network policy if required argument are given. - maybeUpdateServerlessNetworkPolicy(); - objectMapper = new ObjectMapper(); this.initialized = true; LOG.info("Initialized OpenSearch sink");