kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: improve error message for Streams test
Date Sun, 26 Nov 2017 19:33:53 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 5a2960f81 -> 8f6a372ee


MINOR: improve error message for Streams test

Author: Matthias J. Sax <matthias@confluent.io>

Reviewers: Bill Bejeck <bill@confluent.io>, Guozhang Wang <wangguoz@gmail.com>

Closes #4253 from mjsax/minor-imporve-error-message


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8f6a372e
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/8f6a372e
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/8f6a372e

Branch: refs/heads/trunk
Commit: 8f6a372eed3655b3823ac6372821d138879e9d9f
Parents: 5a2960f
Author: Matthias J. Sax <matthias@confluent.io>
Authored: Sun Nov 26 11:33:49 2017 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Sun Nov 26 11:33:49 2017 -0800

----------------------------------------------------------------------
 .../src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/8f6a372e/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java b/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
index 73e7dc3..ab299dd 100644
--- a/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
@@ -402,7 +402,8 @@ public class KafkaStreamsTest {
         assertNotNull(threadMetadata);
         assertEquals(2, threadMetadata.size());
         for (ThreadMetadata metadata : threadMetadata) {
-            assertTrue(Utils.mkList("RUNNING", "CREATED").contains(metadata.threadState()));
+            assertTrue("#threadState() was: " + metadata.threadState() + "; expected either
RUNNING or CREATED",
+                Utils.mkList("RUNNING", "CREATED").contains(metadata.threadState()));
             assertEquals(0, metadata.standbyTasks().size());
             assertEquals(0, metadata.activeTasks().size());
         }


Mime
View raw message