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 2020/04/16 21:22:28 UTC
[kafka] branch trunk updated: HOTFIX: fix active task process ratio
metric recording
This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new a0119aa HOTFIX: fix active task process ratio metric recording
a0119aa is described below
commit a0119aa859ba37f7ed1a2a7c3c00b00672986914
Author: Guozhang Wang <wa...@gmail.com>
AuthorDate: Thu Apr 16 14:21:36 2020 -0700
HOTFIX: fix active task process ratio metric recording
---
.../java/org/apache/kafka/streams/processor/internals/TaskManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
index b725f8a..135a319 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
@@ -833,7 +833,7 @@ public class TaskManager {
}
now = time.milliseconds();
totalProcessed += processed;
- task.recordProcessBatchTime(then - now);
+ task.recordProcessBatchTime(now - then);
} catch (final TaskMigratedException e) {
log.info("Failed to process stream task {} since it got migrated to another thread already. " +
"Will trigger a new rebalance and close all tasks as zombies together.", task.id());