Fix spotlesscheck

Signed-off-by: Liyun Xiu <xiliyun@amazon.com>
opensearch-project · Apr 24, 2024 · 8d302cc · 8d302cc
1 parent b74e142
commit 8d302cc
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 6 deletions.
diff --git a/server/src/test/java/org/opensearch/ingest/IngestServiceTests.java b/server/src/test/java/org/opensearch/ingest/IngestServiceTests.java
@@ -1806,9 +1806,15 @@ public void testExecuteBulkRequestInBatchNoValidPipeline() {
         createPipeline("_id", ingestService);
         BulkRequest bulkRequest = new BulkRequest();
         // will not be handled as not valid document type
-        IndexRequest indexRequest1 = new IndexRequest("_index").id("_id1").source(emptyMap()).setPipeline("_none").setFinalPipeline("_none");
+        IndexRequest indexRequest1 = new IndexRequest("_index").id("_id1")
+            .source(emptyMap())
+            .setPipeline("_none")
+            .setFinalPipeline("_none");
         bulkRequest.add(indexRequest1);
-        IndexRequest indexRequest2 = new IndexRequest("_index").id("_id2").source(emptyMap()).setPipeline("_none").setFinalPipeline("_none");
+        IndexRequest indexRequest2 = new IndexRequest("_index").id("_id2")
+            .source(emptyMap())
+            .setPipeline("_none")
+            .setFinalPipeline("_none");
         bulkRequest.add(indexRequest2);
         bulkRequest.batchIngestionOption("enabled");
         bulkRequest.maximumBatchSize(2);
@@ -1913,7 +1919,8 @@ public void testExecuteBulkRequestInBatchWithExceptionInCallback() {
 
         List<IngestDocumentWrapper> results = Arrays.asList(
             new IngestDocumentWrapper(0, IngestService.toIngestDocument(indexRequest1), null),
-            new IngestDocumentWrapper(1, null, new RuntimeException()));
+            new IngestDocumentWrapper(1, null, new RuntimeException())
+        );
         doAnswer(args -> {
             @SuppressWarnings("unchecked")
             Consumer<List<IngestDocumentWrapper>> handler = (Consumer) args.getArguments()[1];

diff --git a/server/src/test/java/org/opensearch/ingest/ProcessorTests.java b/server/src/test/java/org/opensearch/ingest/ProcessorTests.java
@@ -43,9 +43,7 @@ public void test_batchExecute_success() {
 
     public void test_batchExecute_empty() {
         processor = new FakeProcessor("type", "tag", "description", doc -> { doc.setFieldValue(FIELD_KEY, FIELD_VALUE_PROCESSED); });
-        processor.batchExecute(Collections.emptyList(), results -> {
-            assertEquals(0, results.size());
-        });
+        processor.batchExecute(Collections.emptyList(), results -> { assertEquals(0, results.size()); });
     }
 
     public void test_batchExecute_exception() {