diff --git a/chunjun-core/src/main/java/com/dtstack/chunjun/dirty/manager/DirtyManager.java b/chunjun-core/src/main/java/com/dtstack/chunjun/dirty/manager/DirtyManager.java
index d217352dae..54456d129a 100644
--- a/chunjun-core/src/main/java/com/dtstack/chunjun/dirty/manager/DirtyManager.java
+++ b/chunjun-core/src/main/java/com/dtstack/chunjun/dirty/manager/DirtyManager.java
@@ -131,8 +131,8 @@ public void collect(Object data, Throwable cause, String field, long globalError
         entity.setFieldName(field);
         entity.setErrorMessage(ExceptionUtil.getErrorMessage(cause));
 
-        consumer.offer(entity, globalErrors);
         errorCounter.add(1L);
+        consumer.offer(entity, globalErrors);
     }
 
     public String toString(Object data) {