Revert unnecessary change

Signed-off-by: Chase Engelbrecht <[email protected]>
engechas · Jan 30, 2024 · 3a88a0c · 3a88a0c
1 parent 199f72c
commit 3a88a0c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...arch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSink.java b/...arch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSink.java
@@ -185,8 +185,6 @@ public OpenSearchSink(final PluginSetting pluginSetting,
       dlqPluginSetting.setPipelineName(pluginSetting.getPipelineName());
       dlqProvider = pluginFactory.loadPlugin(DlqProvider.class, dlqPluginSetting);
     }
-
-    this.objectMapper = new ObjectMapper();
   }
 
   @Override
@@ -261,6 +259,8 @@ private void doInitializeInternal() throws IOException {
 
     // Attempt to update the serverless network policy if required argument are given.
     maybeUpdateServerlessNetworkPolicy();
+
+    this.objectMapper = new ObjectMapper();
     this.initialized = true;
     LOG.info("Initialized OpenSearch sink");
   }