kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated: MINOR:Use StoreBuilder.name() for node name (#5588)
Date Thu, 30 Aug 2018 00:42:08 GMT
This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/trunk by this push:
     new 5fb2cdb  MINOR:Use StoreBuilder.name() for node name (#5588)
5fb2cdb is described below

commit 5fb2cdb5c7c4941d3261ec92dc80ca65840de495
Author: Bill Bejeck <bbejeck@gmail.com>
AuthorDate: Wed Aug 29 20:41:58 2018 -0400

    MINOR:Use StoreBuilder.name() for node name (#5588)
    
    Reviewers: Guozhang Wang <guozhang@confluent.io>, John Roesler <john@confluent.io>
---
 .../apache/kafka/streams/kstream/internals/graph/StateStoreNode.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StateStoreNode.java
b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StateStoreNode.java
index a034106..6d3b8ba 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StateStoreNode.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StateStoreNode.java
@@ -25,7 +25,7 @@ public class StateStoreNode extends StreamsGraphNode {
     protected final StoreBuilder storeBuilder;
 
     public StateStoreNode(final StoreBuilder storeBuilder) {
-        super(storeBuilder.toString(), false);
+        super(storeBuilder.name(), false);
 
         this.storeBuilder = storeBuilder;
     }


Mime
View raw message