(iotdb) branch master updated: [Test] Exclude mock initialization from pipe worker timeouts (#18886)

[jiangtian]

This is an automated email from the ASF dual-hosted git repository.

jt2594838 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new f660639add9 [Test] Exclude mock initialization from pipe worker 
timeouts (#18886)
f660639add9 is described below

commit f660639add95e5e4ba392a4cdc2467aaf8aea489
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Thu Oct 15 17:06:50 2026 +0800

    [Test] Exclude mock initialization from pipe worker timeouts (#18886)
---
 .../task/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 6bb09ea9c42..d9aac8ae13f 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
@@ -29,6 +29,7 @@ import 
org.apache.iotdb.db.pipe.resource.memory.PipeMemoryManager.TsFileParserMe
 import com.google.common.util.concurrent.ListeningExecutorService;
 import com.google.common.util.concurrent.ListeningScheduledExecutorService;
 import org.junit.Assert;
+import org.junit.BeforeClass;
 import org.junit.Test;
 import org.mockito.InOrder;
 
@@ -56,6 +57,13 @@ import static org.mockito.Mockito.when;
 
 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();