You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2017/06/20 04:00:47 UTC
kafka git commit: MINOR: StreamThread standbyTask comment typo
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 <qi...@fraudmetrix.cn>
Reviewers: Guozhang Wang <wa...@gmail.com>, Matthias J. Sax <ma...@confluent.io>
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 <qi...@fraudmetrix.cn>
Authored: Mon Jun 19 21:00:32 2017 -0700
Committer: Guozhang Wang <wa...@gmail.com>
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();