kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: StreamThread standbyTask comment typo
Date Tue, 20 Jun 2017 04:01:42 GMT
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 <qihuang.zheng@fraudmetrix.cn>

Reviewers: Guozhang Wang <wangguoz@gmail.com>, Matthias J. Sax <matthias@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/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 <qihuang.zheng@fraudmetrix.cn>
Authored: Mon Jun 19 21:00:32 2017 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
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();


Mime
View raw message