Repository: kafka Updated Branches: refs/heads/trunk f396fdac1 -> c195003cb
HOTFIX: Added check for metadata unavailable Author: Eno Thereska <eno.there...@gmail.com> Reviewers: Damian Guy <damian....@gmail.com>, Ismael Juma <ism...@juma.me.uk> Closes #1887 from enothereska/hotfix-metadata-unavailable Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/c195003c Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c195003c Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/c195003c Branch: refs/heads/trunk Commit: c195003cb6e05f2d8c49285ff7e77b1cb3aa4361 Parents: f396fda Author: Eno Thereska <eno.there...@gmail.com> Authored: Tue Sep 20 11:33:50 2016 +0100 Committer: Ismael Juma <ism...@juma.me.uk> Committed: Tue Sep 20 11:33:50 2016 +0100 ---------------------------------------------------------------------- .../kafka/streams/integration/QueryableStateIntegrationTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/c195003c/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java ---------------------------------------------------------------------- diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java index e6d7be8..66b6d2e 100644 --- a/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java @@ -265,7 +265,7 @@ public class QueryableStateIntegrationTest { public boolean conditionMet() { try { final StreamsMetadata metadata = streams.metadataForKey(storeName, key, new StringSerializer()); - if (metadata == null) { + if (metadata == null || metadata.equals(StreamsMetadata.NOT_AVAILABLE)) { return false; } final int index = metadata.hostInfo().port(); @@ -295,7 +295,7 @@ public class QueryableStateIntegrationTest { public boolean conditionMet() { try { final StreamsMetadata metadata = streams.metadataForKey(storeName, key, new StringSerializer()); - if (metadata == null) { + if (metadata == null || metadata.equals(StreamsMetadata.NOT_AVAILABLE)) { return false; } final int index = metadata.hostInfo().port();
