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 8d4f1f67..ced7fe1d 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
@@ -141,13 +141,20 @@ public abstract class Channel {
 
     public Record pull() {
         Record record = this.doPull();
-        this.statPull(1L, record.getByteSize());
+
+        // record为终止对象时，该记录不算入统计数量
+        if (!(record instanceof TerminateRecord)) {
+            this.statPull(1L, record.getByteSize());
+        }
         return record;
     }
 
     public void pullAll(final Collection<Record> rs) {
         Validate.notNull(rs);
         this.doPullAll(rs);
+
+        // record为终止对象时，该记录不算入统计数量
+        long recordSize = rs.stream().filter(record -> !(record instanceof TerminateRecord)).count();
         this.statPull(rs.size(), this.getByteSize(rs));
     }