From 62110def157a832fdc4a0cd283e4e5a6a5506c02 Mon Sep 17 00:00:00 2001
From: Srikanth Govindarajan <srigovs@amazon.com>
Date: Tue, 12 Nov 2024 15:55:25 -0800
Subject: [PATCH] Address comments

Signed-off-by: Srikanth Govindarajan <srigovs@amazon.com>
---
 .../dataprepper/plugins/lambda/processor/LambdaProcessor.java  | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/data-prepper-plugins/aws-lambda/src/main/java/org/opensearch/dataprepper/plugins/lambda/processor/LambdaProcessor.java b/data-prepper-plugins/aws-lambda/src/main/java/org/opensearch/dataprepper/plugins/lambda/processor/LambdaProcessor.java
index 16bb4e985b..793baad813 100644
--- a/data-prepper-plugins/aws-lambda/src/main/java/org/opensearch/dataprepper/plugins/lambda/processor/LambdaProcessor.java
+++ b/data-prepper-plugins/aws-lambda/src/main/java/org/opensearch/dataprepper/plugins/lambda/processor/LambdaProcessor.java
@@ -245,9 +245,8 @@ boolean flushToLambdaIfNeeded(List<Record<Event>> resultRecords, Buffer currentB
             } catch (IOException e) {
                 LOG.error(NOISY, "Exception while flushing to lambda", e);
                 handleFailure(e, currentBufferPerBatch, resultRecords);
-            } finally {
-                return true;
             }
+            return true;
         }
         return false;
     }