[kafka] branch 1.0 updated: MINOR: Increase timeout and add more context to error message (#5840)

[mj...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/1.0 by this push:
     new 175a930  MINOR: Increase timeout and add more context to error message (#5840)
175a930 is described below

commit 175a9309b1417f6eb44bc484417f5a474142997d
Author: Bill Bejeck <bb...@gmail.com>
AuthorDate: Fri Oct 26 19:10:37 2018 -0400

    MINOR: Increase timeout and add more context to error message (#5840)
    
    Reviewers: John Roesler <jo...@confluent.io>, Matthias J. Sax <ma...@confluent.io>
---
 .../kafka/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 f90dc4b..33f7b70 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 class KStreamKTableJoinIntegrationTest {
             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)