From 4fbbc4e845c96b2a8e8fa7e2316adbbb5b9b5fa4 Mon Sep 17 00:00:00 2001
From: Santhosh Gandhe <1909520+san81@users.noreply.github.com>
Date: Sun, 17 Nov 2024 10:30:38 -0800
Subject: [PATCH] null pointer issue fix

Signed-off-by: Santhosh Gandhe <1909520+san81@users.noreply.github.com>
---
 .../opensearch/dataprepper/plugins/lambda/sink/LambdaSink.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/data-prepper-plugins/aws-lambda/src/main/java/org/opensearch/dataprepper/plugins/lambda/sink/LambdaSink.java b/data-prepper-plugins/aws-lambda/src/main/java/org/opensearch/dataprepper/plugins/lambda/sink/LambdaSink.java
index 427e8c6420..85d2cd07c9 100644
--- a/data-prepper-plugins/aws-lambda/src/main/java/org/opensearch/dataprepper/plugins/lambda/sink/LambdaSink.java
+++ b/data-prepper-plugins/aws-lambda/src/main/java/org/opensearch/dataprepper/plugins/lambda/sink/LambdaSink.java
@@ -9,6 +9,7 @@
 import io.micrometer.core.instrument.DistributionSummary;
 import io.micrometer.core.instrument.Timer;
 import java.time.Duration;
+import java.util.ArrayList;
 import java.util.Collection;
 import java.util.List;
 import java.util.concurrent.TimeUnit;
@@ -152,7 +153,7 @@ public void doOutput(final Collection<Record<Event>> records) {
           numberOfRecordsSuccessCounter.increment(inputBuffer.getEventCount());
           numberOfRequestsSuccessCounter.increment();
           releaseEventHandlesPerBatch(true, inputBuffer);
-          return null;
+          return new ArrayList<>();
         },
         (inputBuffer, invokeResponse) -> {
           Duration latency = inputBuffer.stopLatencyWatch();