Fix null document in DLQ object (opensearch-project#4814)

* dplive1.yaml Signed-off-by: Krishna Kondaka <[email protected]> * Delete .github/workflows/static.yml Signed-off-by: Krishna Kondaka <[email protected]> * Fix null document in DLQ object Signed-off-by: Krishna Kondaka <[email protected]> --------- Signed-off-by: Krishna Kondaka <[email protected]> Co-authored-by: Krishna Kondaka <[email protected]> Signed-off-by: Krishna Kondaka <[email protected]>
kkondaka · Aug 14, 2024 · d2c4ea4 · d2c4ea4
1 parent 0a1993a
commit d2c4ea4
Showing 1 changed file with 3 additions and 3 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
@@ -448,9 +448,9 @@ public void doOutput(final Collection<Record<Event>> records) {
       }
 
       SerializedJson serializedJsonNode = null;
-      if (StringUtils.equals(action, OpenSearchBulkActions.UPDATE.toString()) ||
-          StringUtils.equals(action, OpenSearchBulkActions.UPSERT.toString()) ||
-          StringUtils.equals(action, OpenSearchBulkActions.DELETE.toString())) {
+      if (StringUtils.equals(eventAction, OpenSearchBulkActions.UPDATE.toString()) ||
+          StringUtils.equals(eventAction, OpenSearchBulkActions.UPSERT.toString()) ||
+          StringUtils.equals(eventAction, OpenSearchBulkActions.DELETE.toString())) {
             serializedJsonNode = SerializedJson.fromJsonNode(event.getJsonNode(), document);
       }
       BulkOperation bulkOperation;