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:39:00 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk f396fdac1 -> c195003cb


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


Mime
View raw message