kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch 0.11.0 updated: MINOR: remove idempotent statement (#5659)
Date Thu, 20 Sep 2018 00:17:39 GMT
This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/0.11.0 by this push:
     new 6a7652f  MINOR: remove idempotent statement (#5659)
6a7652f is described below

commit 6a7652fe0fe16b57156e1e31e6e1cd8580bcbd6f
Author: Matthias J. Sax <mjsax@apache.org>
AuthorDate: Wed Sep 19 17:17:28 2018 -0700

    MINOR: remove idempotent statement (#5659)
    
    Reviewers: John Roesler <john@confluent.io>, Bill Bejeck <bill@confluent.io>,
Guozhang Wang <guozhang@confluent.io>
---
 .../apache/kafka/streams/processor/internals/StoreChangelogReader.java | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
index 305bf10..1fbaf95 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
@@ -180,7 +180,6 @@ public class StoreChangelogReader implements ChangelogReader {
                             "Reinitializing the task and restore its state from the beginning.",
task.id, restorer.storeName(), restorer.partition());
 
                         needsInitializing.remove(restoringPartition);
-                        initialized.put(restoringPartition, restorer);
                         restorer.setCheckpointOffset(consumer.position(restoringPartition));
 
                         task.reinitializeStateStoresForPartitions(restoringPartition);
@@ -196,8 +195,6 @@ public class StoreChangelogReader implements ChangelogReader {
                     }
                 }
             }
-
-
         }
 
         needsRestoring.putAll(initialized);


Mime
View raw message