From b2f6a2b52a75f36634866546cbc03e98e0834baf Mon Sep 17 00:00:00 2001
From: Caideyipi <87789683+Caideyipi@users.noreply.github.com>
Date: Thu, 15 Oct 2026 17:06:50 +0800
Subject: [PATCH] [Test] Exclude mock initialization from pipe worker timeouts
 (#18886)

(cherry picked from commit f660639add95e5e4ba392a4cdc2467aaf8aea489)
---
 .../subtask/processor/PipeProcessorSubtaskWorkerTest.java | 8 ++++++++
 1 file changed, 8 insertions(+)

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();