diff --git a/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/batching/BatcherImplTest.java b/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/batching/BatcherImplTest.java index ce4f43b45c53..a6489aa26aff 100644 --- a/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/batching/BatcherImplTest.java +++ b/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/batching/BatcherImplTest.java @@ -516,7 +516,6 @@ void testWhenDelayThresholdExceeds() throws Exception { /** Validates that the elements are not leaking to multiple batches */ @Test - @Timeout(value = 500, unit = TimeUnit.MILLISECONDS) void testElementsNotLeaking() throws Exception { ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor(); ScheduledExecutorService multiThreadExecutor = Executors.newScheduledThreadPool(20); @@ -567,7 +566,7 @@ public ApiFuture> futureCall( } // Closing the resources - future.get(); + future.get(10, TimeUnit.SECONDS); assertThat(isDuplicateElement.get()).isFalse(); singleThreadExecutor.shutdown(); multiThreadExecutor.shutdown();