Caideyipi opened a new pull request, #18244: URL: https://github.com/apache/iotdb/pull/18244
## Description `SharedTsBlockQueueTest.concurrencyTest` used a fixed JUnit timeout while polling counters, printing progress, and recursively scheduling listener tasks. Under CI load, the test could time out without surfacing worker failures, and its executor was never shut down. This change makes the test deterministic by: - waiting for producer and consumer tasks through `Future.get` - propagating worker failures to the test thread - using the real memory manager and pool instead of unnecessary spies - asserting the final queue and memory state - always shutting down the executor ## Testing - `mvn -o -nsu -Ddevelocity.off=true spotless:check -pl iotdb-core/datanode` - compiled and ran `SharedTsBlockQueueTest` directly: 2 tests passed - repeated the complete test class 20 times: 20/20 passed A full reactor test attempt was blocked before reaching DataNode by an existing generated Thrift compilation error: `TaskType.java` could not resolve `javax.annotation`. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
