Increased wait time

Signed-off-by: Kondaka <[email protected]>
kkondaka · Nov 27, 2023 · a58651f · a58651f
1 parent 8d4787b
commit a58651f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...est/java/org/opensearch/dataprepper/plugins/processor/aggregate/AggregateProcessorIT.java b/...est/java/org/opensearch/dataprepper/plugins/processor/aggregate/AggregateProcessorIT.java
@@ -285,7 +285,7 @@ void aggregateWithPercentSamplerAction(double testPercent) throws InterruptedExc
             });
         }
 
-        boolean allThreadsFinished = countDownLatch.await(10L, TimeUnit.SECONDS);
+        boolean allThreadsFinished = countDownLatch.await(20L, TimeUnit.SECONDS);
 
         assertThat(allThreadsFinished, equalTo(true));
         assertThat((double)allowedEventsCount.get(), closeTo(NUM_THREADS * NUM_EVENTS_PER_BATCH * testPercent/100, 1.0));