Repository: kafka Updated Branches: refs/heads/trunk 198a43d84 -> ea2a21dda
MINOR: StreamThread standbyTask comment typo log info typos. should be standby task, not active task. Author: zqhxuyuan <[email protected]> Reviewers: Guozhang Wang <[email protected]>, Matthias J. Sax <[email protected]> Closes #3362 from zqhxuyuan/trunk Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ea2a21dd Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ea2a21dd Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ea2a21dd Branch: refs/heads/trunk Commit: ea2a21dda4ee402cf06e127609456b11c5997d37 Parents: 198a43d Author: Qihuang Zheng <[email protected]> Authored: Mon Jun 19 21:00:32 2017 -0700 Committer: Guozhang Wang <[email protected]> Committed: Mon Jun 19 21:00:32 2017 -0700 ---------------------------------------------------------------------- .../org/apache/kafka/streams/processor/internals/StreamThread.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/ea2a21dd/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java index 1280f46..887e4b5 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java @@ -1342,7 +1342,7 @@ public class StreamThread extends Thread { final Map<TaskId, Set<TopicPartition>> newStandbyTasks = new HashMap<>(); - log.info("{} Adding assigned standby tasks {}", logPrefix, partitionAssignor.activeTasks()); + log.info("{} Adding assigned standby tasks {}", logPrefix, partitionAssignor.standbyTasks()); // collect newly assigned standby tasks and reopen re-assigned standby tasks for (final Map.Entry<TaskId, Set<TopicPartition>> entry : partitionAssignor.standbyTasks().entrySet()) { final TaskId taskId = entry.getKey();
