This is an automated email from the ASF dual-hosted git repository.
lihaosky pushed a commit to branch release-2.3
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-2.3 by this push:
new 0831fffbb3e [FLINK-39919][connector-base/tests] Increase the timeout
for SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown to get
stable (#28420)
0831fffbb3e is described below
commit 0831fffbb3eb2908e0acf22166fb27349539310a
Author: Yuepeng Pan <[email protected]>
AuthorDate: Sun Jun 14 01:38:59 2026 +0800
[FLINK-39919][connector-base/tests] Increase the timeout for
SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown to get
stable (#28420)
---
.../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(
