From 8fb0f8590647fd5c7893e8143f7e00bb1abc9120 Mon Sep 17 00:00:00 2001
From: chenyang <chenyangliuhua@gmail.com>
Date: Wed, 21 Jul 2021 14:46:09 +0800
Subject: [PATCH] Update Channel.java

---
 .../java/com/alibaba/datax/core/transport/channel/Channel.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/main/java/com/alibaba/datax/core/transport/channel/Channel.java b/core/src/main/java/com/alibaba/datax/core/transport/channel/Channel.java
index ced7fe1d..119ef965 100755
--- a/core/src/main/java/com/alibaba/datax/core/transport/channel/Channel.java
+++ b/core/src/main/java/com/alibaba/datax/core/transport/channel/Channel.java
@@ -155,7 +155,7 @@ public abstract class Channel {
 
         // record为终止对象时，该记录不算入统计数量
         long recordSize = rs.stream().filter(record -> !(record instanceof TerminateRecord)).count();
-        this.statPull(rs.size(), this.getByteSize(rs));
+        this.statPull(recordSize, this.getByteSize(rs));
     }
 
     protected abstract void doPush(Record r);