root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

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
This commit is contained in:
Damian Guy 2017-06-30 17:15:23 +01:00
parent 7429f49780
commit 17bdd4831c
1 changed files with 0 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
View File

@ -58,7 +58,6 @@ public class ProcessorStateManager implements StateManager {
private final Map<TopicPartition, Long> checkpointedOffsets; 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, StateRestoreCallback> restoreCallbacks; // used for standby tasks, keyed by state topic name
private final Map<String, String> storeToChangelogTopic; private final Map<String, String> storeToChangelogTopic;
private final boolean eosEnabled;
// TODO: this map does not work with customized grouper where multiple partitions // TODO: this map does not work with customized grouper where multiple partitions
// of the same topic can be assigned to the same topic. // of the same topic can be assigned to the same topic.
@ -93,7 +92,6 @@ public class ProcessorStateManager implements StateManager {
this.isStandby = isStandby; this.isStandby = isStandby;
restoreCallbacks = isStandby ? new HashMap<String, StateRestoreCallback>() : null; restoreCallbacks = isStandby ? new HashMap<String, StateRestoreCallback>() : null;
this.storeToChangelogTopic = storeToChangelogTopic; this.storeToChangelogTopic = storeToChangelogTopic;
this.eosEnabled = eosEnabled;
if (!stateDirectory.lock(taskId, 5)) { if (!stateDirectory.lock(taskId, 5)) {
throw new LockException(String.format("%s Failed to lock the state directory for task %s", throw new LockException(String.format("%s Failed to lock the state directory for task %s",