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;
}