Repository: kafka Updated Branches: refs/heads/1.0 2c3431744 -> 53c9dd342
MINOR: improve error message for Streams test Author: Matthias J. Sax <matth...@confluent.io> Reviewers: Bill Bejeck <b...@confluent.io>, Guozhang Wang <wangg...@gmail.com> Closes #4253 from mjsax/minor-imporve-error-message (cherry picked from commit 8f6a372eed3655b3823ac6372821d138879e9d9f) Signed-off-by: Guozhang Wang <wangg...@gmail.com> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/53c9dd34 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/53c9dd34 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/53c9dd34 Branch: refs/heads/1.0 Commit: 53c9dd3421228078c898f5f2b689d01dc9a6da75 Parents: 2c34317 Author: Matthias J. Sax <matth...@confluent.io> Authored: Sun Nov 26 11:33:49 2017 -0800 Committer: Guozhang Wang <wangg...@gmail.com> Committed: Sun Nov 26 11:34:08 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/53c9dd34/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 dd3b9af..112f1b7 100644 --- a/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java @@ -406,7 +406,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()); }
