You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by li...@apache.org on 2026/06/13 17:38:27 UTC
(flink) branch master updated: [FLINK-39919][connector-base/tests] Increase the timeout for SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown to get stable (#28419)
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 <pa...@apache.org>
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(