Repository: kafka
Updated Branches:
  refs/heads/0.10.1 f66e88a30 -> fc5f48aad


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/fc5f48aa
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/fc5f48aa
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/fc5f48aa

Branch: refs/heads/0.10.1
Commit: fc5f48aad4952df88147675a663ad034ce15d13d
Parents: f66e88a
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:40:07 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/fc5f48aa/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();

Reply via email to