From ab6060fb2d6caac2c9be119879838dcfe257324e Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Mon, 23 May 2022 12:08:03 -0400 Subject: [PATCH] The `testWindowTimespan()` is time-sensitive The `FluxAggregatorMessageHandlerTests.testWindowTimespan()` relies on the time-based window function of `100` millis. Looks like a delay of `Thread.sleep(20)` may cause a resources race condition and window is released only with one item. * Disable `testWindowTimespan()` since there is no guarantee with what timing settings it is going to work stably **Cherry-pick to `5.5.x`** --- .../aggregator/FluxAggregatorMessageHandlerTests.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/spring-integration-core/src/test/java/org/springframework/integration/aggregator/FluxAggregatorMessageHandlerTests.java b/spring-integration-core/src/test/java/org/springframework/integration/aggregator/FluxAggregatorMessageHandlerTests.java index 88ce4a3655..421e9ce3e4 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/aggregator/FluxAggregatorMessageHandlerTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/aggregator/FluxAggregatorMessageHandlerTests.java @@ -25,6 +25,7 @@ import java.util.concurrent.Executors; import java.util.stream.Collectors; import java.util.stream.IntStream; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.springframework.integration.IntegrationMessageHeaderAccessor; @@ -157,6 +158,7 @@ class FluxAggregatorMessageHandlerTests { } @Test + @Disabled("Time-sensitive") void testWindowTimespan() { QueueChannel resultChannel = new QueueChannel(); FluxAggregatorMessageHandler fluxAggregatorMessageHandler = new FluxAggregatorMessageHandler();