HOTFIX: fix active task process ratio metric recording
@@ -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());
