kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: HOTFIX: Added check for metadata unavailable
Date Tue, 20 Sep 2016 10:40:15 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.1 f66e88a30 -> fc5f48aad


HOTFIX: Added check for metadata unavailable

Author: Eno Thereska <eno.thereska@gmail.com>

Reviewers: Damian Guy <damian.guy@gmail.com>, Ismael Juma <ismael@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.thereska@gmail.com>
Authored: Tue Sep 20 11:33:50 2016 +0100
Committer: Ismael Juma <ismael@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();


Mime
View raw message