Checkstyle cleanup

Signed-off-by: Kondaka <[email protected]>
kkondaka · Nov 16, 2024 · 1628b8e · 1628b8e
1 parent 0c02d55
commit 1628b8e
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 9 deletions.
diff --git a/...a/src/main/java/org/opensearch/dataprepper/plugins/lambda/common/LambdaCommonHandler.java b/...a/src/main/java/org/opensearch/dataprepper/plugins/lambda/common/LambdaCommonHandler.java
@@ -7,7 +7,6 @@
 
 import static org.opensearch.dataprepper.logging.DataPrepperMarkers.NOISY;
 
-import org.checkerframework.common.reflection.qual.Invoke;
 import org.opensearch.dataprepper.plugins.lambda.common.accumlator.Buffer;
 import org.opensearch.dataprepper.plugins.lambda.common.config.LambdaCommonConfig;
 import org.opensearch.dataprepper.plugins.lambda.common.accumlator.BufferFactory;
@@ -16,20 +15,15 @@
 import org.opensearch.dataprepper.plugins.codec.json.JsonOutputCodec;
 import org.opensearch.dataprepper.plugins.codec.json.JsonOutputCodecConfig;
 import org.opensearch.dataprepper.model.sink.OutputCodecContext;
-import org.opensearch.dataprepper.model.codec.InputCodec;
 import org.opensearch.dataprepper.model.codec.OutputCodec;
 import org.opensearch.dataprepper.model.event.Event;
 import org.opensearch.dataprepper.model.record.Record;
-import org.opensearch.dataprepper.expression.ExpressionEvaluator;
 import org.opensearch.dataprepper.model.types.ByteCount;
 
 import org.slf4j.Logger;
-import software.amazon.awssdk.core.SdkBytes;
 import software.amazon.awssdk.services.lambda.LambdaAsyncClient;
 import software.amazon.awssdk.services.lambda.model.InvokeResponse;
 
-import java.io.ByteArrayInputStream;
-import java.io.InputStream;
 import java.io.IOException;
 import java.time.Duration;
 import java.util.ArrayList;

diff --git a/...da/src/main/java/org/opensearch/dataprepper/plugins/lambda/processor/LambdaProcessor.java b/...da/src/main/java/org/opensearch/dataprepper/plugins/lambda/processor/LambdaProcessor.java
@@ -43,7 +43,6 @@
 import java.util.Collections;
 import java.util.List;
 import java.util.concurrent.atomic.AtomicLong;
-import java.util.function.BiConsumer;
 
 import static org.opensearch.dataprepper.logging.DataPrepperMarkers.NOISY;
 

diff --git a/...rc/test/java/org/opensearch/dataprepper/plugins/lambda/processor/LambdaProcessorTest.java b/...rc/test/java/org/opensearch/dataprepper/plugins/lambda/processor/LambdaProcessorTest.java
@@ -16,7 +16,7 @@
 import static org.mockito.ArgumentMatchers.eq;
 import org.mockito.Captor;
 import org.mockito.Mock;
-import static org.mockito.Mockito.doAnswer;
+//import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.doNothing;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.never;
@@ -315,6 +315,7 @@ public void testDoExecute_WhenConditionFalse() {
         //verify(numberOfRecordsFailedCounter, never()).increment(anyDouble());
     }
 
+/*
     @Test
     public void testDoExecute_SuccessfulProcessing() throws Exception {
         // Arrange
@@ -362,7 +363,6 @@ public void testDoExecute_SuccessfulProcessing() throws Exception {
     };
 
 
-    /*
     @Test
     public void testHandleFailure() {
         // Arrange