diff --git a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats/ConnectStatsService.java b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats/ConnectStatsService.java
index d7c3c6520..0028058fd 100644
--- a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats/ConnectStatsService.java
+++ b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats/ConnectStatsService.java
@@ -271,8 +271,8 @@ private void sampling() {
             }
 
             this.sinkTaskTimesList.add(new CallSnapshot(System.currentTimeMillis(), sinkTaskTimesTotal()));
-            if (this.sourceTaskTimesList.size() > (MAX_RECORDS_OF_SAMPLING + 1)) {
-                this.sourceTaskTimesList.removeFirst();
+            if (this.sinkTaskTimesList.size() > (MAX_RECORDS_OF_SAMPLING + 1)) {
+                this.sinkTaskTimesList.removeFirst();
             }
         } finally {
             this.lockSampling.unlock();