diff --git a/server/src/test/java/org/elasticsearch/action/ingest/SimulateExecutionServiceTests.java b/server/src/test/java/org/elasticsearch/action/ingest/SimulateExecutionServiceTests.java index fabcf16537427..7276ef2ebada4 100644 --- a/server/src/test/java/org/elasticsearch/action/ingest/SimulateExecutionServiceTests.java +++ b/server/src/test/java/org/elasticsearch/action/ingest/SimulateExecutionServiceTests.java @@ -42,6 +42,7 @@ import java.util.List; import java.util.Map; import java.util.concurrent.CountDownLatch; +import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicReference; import java.util.function.BiConsumer; @@ -378,7 +379,7 @@ public String getType() { errorHolder.set(e); latch.countDown(); })); - latch.await(); + latch.await(1, TimeUnit.MINUTES); assertThat(errorHolder.get(), nullValue()); SimulatePipelineResponse response = responseHolder.get(); assertThat(response, notNullValue());