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 <[email protected]>
AuthorDate: Wed Aug 29 20:41:58 2018 -0400

    MINOR:Use StoreBuilder.name() for node name (#5588)
    
    Reviewers: Guozhang Wang <[email protected]>, John Roesler 
<[email protected]>
---
 .../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;
     }

Reply via email to