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.