null pointer issue fix

Signed-off-by: Santhosh Gandhe <[email protected]>
kkondaka · Nov 17, 2024 · 4fbbc4e · 4fbbc4e
1 parent 1ff5e44
commit 4fbbc4e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...s/aws-lambda/src/main/java/org/opensearch/dataprepper/plugins/lambda/sink/LambdaSink.java b/...s/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();