github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-03 01:30:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update Channel.java

Browse Source
This commit is contained in:
chenyang 2021-07-21 14:46:09 +08:00 committed by GitHub
parent 4df71b8c2d
commit 8fb0f85906
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/main/java/com/alibaba/datax/core/transport/channel/Channel.java
View File

@ -155,7 +155,7 @@ public abstract class Channel {
// record为终止对象时，该记录不算入统计数量 // record为终止对象时，该记录不算入统计数量
long recordSize = rs.stream().filter(record -> !(record instanceof TerminateRecord)).count(); 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); protected abstract void doPush(Record r);