diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/processor/PipeProcessorSubtaskWorkerTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/processor/PipeProcessorSubtaskWorkerTest.java
index d1d24c118373..deb1219f0fe9 100644
--- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/processor/PipeProcessorSubtaskWorkerTest.java
+++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/processor/PipeProcessorSubtaskWorkerTest.java
@@ -30,6 +30,7 @@
 import com.google.common.util.concurrent.ListeningScheduledExecutorService;
 import org.apache.commons.lang3.StringUtils;
 import org.junit.Assert;
+import org.junit.BeforeClass;
 import org.junit.Test;
 import org.mockito.InOrder;
 
@@ -57,6 +58,13 @@
 
 public class PipeProcessorSubtaskWorkerTest {
 
+  @BeforeClass
+  public static void initializeSubtaskMock() {
+    // Mockito/Byte Buddy initialization can be slow in a fresh CI fork. Keep that class loading
+    // outside the test timeouts so they measure worker notifications instead of mock startup.
+    mock(PipeProcessorSubtask.class);
+  }
+
   @Test(timeout = 30000)
   public void testOneHundredWaitingPipesDoNotWaitForWorkerPolling() throws Exception {
     final CommonConfig config = CommonDescriptor.getInstance().getConfig();