Return-Path: <commits-return-7129-archive-asf-public=cust-asf.ponee.io@kafka.apache.org>
X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io
Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io
Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183])
	by cust-asf2.ponee.io (Postfix) with ESMTP id 4AD72200CBB
	for <archive-asf-public-internal@cust-asf2.ponee.io>; Tue, 20 Jun 2017 06:01:44 +0200 (CEST)
Received: by cust-asf.ponee.io (Postfix)
	id 48D16160BE4; Tue, 20 Jun 2017 04:01:44 +0000 (UTC)
Delivered-To: archive-asf-public@cust-asf.ponee.io
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by cust-asf.ponee.io (Postfix) with SMTP id 8F0C5160BE1
	for <archive-asf-public@cust-asf.ponee.io>; Tue, 20 Jun 2017 06:01:43 +0200 (CEST)
Received: (qmail 89760 invoked by uid 500); 20 Jun 2017 04:01:42 -0000
Mailing-List: contact commits-help@kafka.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:commits-help@kafka.apache.org>
List-Unsubscribe: <mailto:commits-unsubscribe@kafka.apache.org>
List-Post: <mailto:commits@kafka.apache.org>
List-Id: <commits.kafka.apache.org>
Reply-To: dev@kafka.apache.org
Delivered-To: mailing list commits@kafka.apache.org
Received: (qmail 89750 invoked by uid 99); 20 Jun 2017 04:01:42 -0000
Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 20 Jun 2017 04:01:42 +0000
Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33)
	id 8B5A6DFE22; Tue, 20 Jun 2017 04:01:42 +0000 (UTC)
Content-Type: text/plain; charset="us-ascii"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
From: guozhang@apache.org
To: commits@kafka.apache.org
Message-Id: <81b9d81e08d642c5bde5d3c787c7a6bb@git.apache.org>
X-Mailer: ASF-Git Admin Mailer
Subject: kafka git commit: MINOR: StreamThread standbyTask comment typo
Date: Tue, 20 Jun 2017 04:01:42 +0000 (UTC)
archived-at: Tue, 20 Jun 2017 04:01:44 -0000

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();