kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch 2.4 updated: HOTFIX: use equals() to compare HostInfo in StreamsMetadataState (#8919)
Date Wed, 24 Jun 2020 01:52:31 GMT
This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch 2.4
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.4 by this push:
     new a91e91b  HOTFIX: use equals() to compare HostInfo in StreamsMetadataState (#8919)
a91e91b is described below

commit a91e91b31b7d03acf43367a9230484d431ffd193
Author: A. Sophie Blee-Goldman <sophie@confluent.io>
AuthorDate: Tue Jun 23 18:37:11 2020 -0700

    HOTFIX: use equals() to compare HostInfo in StreamsMetadataState (#8919)
    
    Reviewer: Matthias J. Sax <matthias@confluent.io>
---
 .../kafka/streams/processor/internals/StreamsMetadataState.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java
index 27826a6..e81ff61 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java
@@ -141,7 +141,7 @@ public class StreamsMetadataState {
         if (globalStores.contains(storeName)) {
             // global stores are on every node. if we dont' have the host info
             // for this host then just pick the first metadata
-            if (thisHost == UNKNOWN_HOST) {
+            if (thisHost.equals(UNKNOWN_HOST)) {
                 return allMetadata.get(0);
             }
             return myMetadata;
@@ -189,7 +189,7 @@ public class StreamsMetadataState {
         if (globalStores.contains(storeName)) {
             // global stores are on every node. if we dont' have the host info
             // for this host then just pick the first metadata
-            if (thisHost == UNKNOWN_HOST) {
+            if (thisHost.equals(UNKNOWN_HOST)) {
                 return allMetadata.get(0);
             }
             return myMetadata;


Mime
View raw message