You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2018/05/30 18:09:15 UTC
[kafka] branch trunk updated: Remove duplicate code which is
invoked twice (#5039)
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 2b6630b Remove duplicate code which is invoked twice (#5039)
2b6630b is described below
commit 2b6630b518c7edb74b2fc225c2bcd39ef5e4aa26
Author: Dark <ek...@gmail.com>
AuthorDate: Thu May 31 03:09:12 2018 +0900
Remove duplicate code which is invoked twice (#5039)
Reviewers: Ismael Juma <is...@juma.me.uk>, Guozhang Wang <wa...@gmail.com>
---
.../main/java/org/apache/kafka/streams/state/internals/NamedCache.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java
index d058c9c..6a3d197 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java
@@ -257,7 +257,6 @@ class NamedCache {
}
remove(node);
- cache.remove(key);
dirtyKeys.remove(key);
currentSizeBytes -= node.size();
return node.entry();
--
To stop receiving notification emails like this one, please contact
guozhang@apache.org.