You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2017/06/30 16:15:29 UTC
kafka git commit: MINOR: remove unused eosEnabled field from
ProcessorStateManager
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 <da...@gmail.com>
Reviewers: Guozhang Wang <wa...@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 <da...@gmail.com>
Authored: Fri Jun 30 17:15:23 2017 +0100
Committer: Damian Guy <da...@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",