diff --git a/data-prepper-plugins/opensearch/src/integrationTest/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSinkIT.java b/data-prepper-plugins/opensearch/src/integrationTest/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSinkIT.java index 2e83534ba0..b87c5f0c34 100644 --- a/data-prepper-plugins/opensearch/src/integrationTest/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSinkIT.java +++ b/data-prepper-plugins/opensearch/src/integrationTest/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSinkIT.java @@ -888,7 +888,8 @@ public void testOpenSearchBulkActionsCreateWithExpression() throws IOException, Map metadata = initializeConfigurationMetadata(null, testIndexAlias, testTemplateFile); metadata.put(IndexConfiguration.DOCUMENT_ID_FIELD, testIdField); Event event = (Event) testRecords.get(0).getData(); - event.getMetadata().setAttribute("action", "create");metadata.put(IndexConfiguration.ACTION, "create"); + event.getMetadata().setAttribute("action", "create"); + metadata.put(IndexConfiguration.ACTION, "create"); final OpenSearchSinkConfig openSearchSinkConfig = generateOpenSearchSinkConfigByMetadata(metadata); final OpenSearchSink sink = createObjectUnderTest(openSearchSinkConfig, true); sink.output(testRecords);