From bc6abd210fae139e43751dece3f54e6eb12c3f40 Mon Sep 17 00:00:00 2001
From: Bill Bejeck <bill@confluent.io>
Date: Thu, 25 Oct 2018 11:32:16 -0400
Subject: [PATCH] MINOR: Increase timeout and add more context to error message

---
 .../streams/integration/KStreamKTableJoinIntegrationTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/KStreamKTableJoinIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/KStreamKTableJoinIntegrationTest.java
index f90dc4bc174d5..33f7b70298374 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/KStreamKTableJoinIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/KStreamKTableJoinIntegrationTest.java
@@ -319,7 +319,7 @@ public void apply(final String key, final Long value) {
             public boolean conditionMet() {
                 return remainingExpectedResult.isEmpty();
             }
-        }, "Never received expected result.");
+        }, 30000, "Never received all expected results.  Still waiting for " + remainingExpectedResult);
 
         final int expectedResultSize = expectedClicksPerRegion.size();
         final int expectedNumberOfOutputs = (cacheSizeBytes == 0)