This is an automated email from the ASF dual-hosted git repository.
lihaosky pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 9540d89d121 [FLINK-39919][connector-base/tests] Increase the timeout
for SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown to get
stable (#28419)
9540d89d121 is described below
commit 9540d89d12153d71b26ab5628be957f8b638dc2d
Author: Yuepeng Pan <[email protected]>
AuthorDate: Sun Jun 14 01:38:22 2026 +0800
[FLINK-39919][connector-base/tests] Increase the timeout for
SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown to get
stable (#28419)
---
.../connector/base/source/reader/fetcher/SplitFetcherManagerTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherManagerTest.java
b/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherManagerTest.java
index 03f9df713a8..742571e37dd 100644
---
a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherManagerTest.java
+++
b/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherManagerTest.java
@@ -130,7 +130,7 @@ class SplitFetcherManagerTest {
waitUntil(
() ->
findThread(SplitFetcherManager.THREAD_NAME_PREFIX).size() == 2,
- Duration.ofSeconds(30),
+ Duration.ofSeconds(60),
"The element queue draining thread should have started.");
for (Thread t : findThread(SplitFetcherManager.THREAD_NAME_PREFIX)) {
waitUntil(
