diff --git a/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/ByteStreamWritingMessageHandlerTests.java b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/ByteStreamWritingMessageHandlerTests.java
index 62f7977dbb..f0857fbae0 100644
--- a/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/ByteStreamWritingMessageHandlerTests.java
+++ b/org.springframework.integration.stream/src/test/java/org/springframework/integration/stream/ByteStreamWritingMessageHandlerTests.java
@@ -251,7 +251,7 @@ public class ByteStreamWritingMessageHandlerTests {
 
 		public void await() {
 			try {
-				this.latch.await(1000, TimeUnit.MILLISECONDS);
+				this.latch.await(3000, TimeUnit.MILLISECONDS);
 				if (latch.getCount() != 0) {
 					throw new RuntimeException("test timeout");
 				}