kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From damian...@apache.org
Subject kafka git commit: MINOR: remove unused eosEnabled field from ProcessorStateManager
Date Fri, 30 Jun 2017 16:15:29 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 7429f4978 -> 17bdd4831


MINOR: remove unused eosEnabled field from ProcessorStateManager

remove unused eosEnabled field from ProcessorStateManager

Author: Damian Guy <damian.guy@gmail.com>

Reviewers: Guozhang Wang <wangguoz@gmail.com>

Closes #3469 from dguy/minor-remove-unused-boolean


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/17bdd483
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/17bdd483
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/17bdd483

Branch: refs/heads/trunk
Commit: 17bdd4831c0098ea2c50e9bad1bf8ba70352854c
Parents: 7429f49
Author: Damian Guy <damian.guy@gmail.com>
Authored: Fri Jun 30 17:15:23 2017 +0100
Committer: Damian Guy <damian.guy@gmail.com>
Committed: Fri Jun 30 17:15:23 2017 +0100

----------------------------------------------------------------------
 .../kafka/streams/processor/internals/ProcessorStateManager.java   | 2 --
 1 file changed, 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/17bdd483/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
index 226d7eb..b1dcdf7 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
@@ -58,7 +58,6 @@ public class ProcessorStateManager implements StateManager {
     private final Map<TopicPartition, Long> checkpointedOffsets;
     private final Map<String, StateRestoreCallback> restoreCallbacks; // used for standby
tasks, keyed by state topic name
     private final Map<String, String> storeToChangelogTopic;
-    private final boolean eosEnabled;
 
     // TODO: this map does not work with customized grouper where multiple partitions
     // of the same topic can be assigned to the same topic.
@@ -93,7 +92,6 @@ public class ProcessorStateManager implements StateManager {
         this.isStandby = isStandby;
         restoreCallbacks = isStandby ? new HashMap<String, StateRestoreCallback>()
: null;
         this.storeToChangelogTopic = storeToChangelogTopic;
-        this.eosEnabled = eosEnabled;
 
         if (!stateDirectory.lock(taskId, 5)) {
             throw new LockException(String.format("%s Failed to lock the state directory
for task %s",


Mime
View raw message