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....@gmail.com> Reviewers: Guozhang Wang <wangg...@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....@gmail.com> Authored: Fri Jun 30 17:15:23 2017 +0100 Committer: Damian Guy <damian....@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",
