Repository: kafka Updated Branches: refs/heads/0.11.0 5b3512166 -> e62d0df37
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/e62d0df3 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/e62d0df3 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/e62d0df3 Branch: refs/heads/0.11.0 Commit: e62d0df37299168ef1aa1965eb2e13dd515b7ff9 Parents: 5b35121 Author: Qihuang Zheng <[email protected]> Authored: Mon Jun 19 21:00:32 2017 -0700 Committer: Guozhang Wang <[email protected]> Committed: Mon Jun 19 21:01:35 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/e62d0df3/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();
