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 7764b2e9e8..54736c0885 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
@@ -434,7 +434,7 @@ public void doOutput(final Collection<Record<Event>> records) {
         event.put("index", docIndexName);
         replacementFields.forEach(field -> event.put(field, List.of(docId)));
       } else {
-        replacementFields.forEach(field -> event.put(field, Collections.emptyList());
+        replacementFields.forEach(field -> event.put(field, Collections.emptyList()));
       }
 
       event.delete("RULE_ENGINE_DOC_MATCH_ID");