fixing test

masseyke · Dec 1, 2023 · c454aff · c454aff
1 parent 249220b
commit c454aff
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/.../java/org/elasticsearch/xpack/application/analytics/ingest/BulkProcessorFactoryTests.java b/.../java/org/elasticsearch/xpack/application/analytics/ingest/BulkProcessorFactoryTests.java
@@ -60,8 +60,9 @@ public void testConfigValueAreUsed() throws Exception {
 
         BulkProcessor2.Builder baseBuilder = spy(BulkProcessor2.builder(mock(), new BulkProcessorFactory.BulkProcessorListener(), mock()));
         BulkProcessorFactory factory = new BulkProcessorFactory(config, () -> baseBuilder);
-
-        assertThat(factory.create(), instanceOf(BulkProcessor2.class));
+        try (BulkProcessor2 bulkProcessor = factory.create()) {
+            assertThat(bulkProcessor, instanceOf(BulkProcessor2.class));
+        }
 
         verify(baseBuilder).setFlushInterval(eq(flushDelay));
         verify(baseBuilder).setBulkActions(eq(maxBulkActions));