This is an automated email from the ASF dual-hosted git repository.
jqin 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 cc0a8b3f69b [FLINK-36292][Connectors/Common][test]: remove timeout to
avoid timeout exception (#25371)
cc0a8b3f69b is described below
commit cc0a8b3f69b8036534a5f0132bbe8f470d945ca0
Author: Luke Chen <[email protected]>
AuthorDate: Fri Sep 27 03:25:07 2024 +0900
[FLINK-36292][Connectors/Common][test]: remove timeout to avoid timeout
exception (#25371)
---
.../connector/base/source/reader/fetcher/SplitFetcherManagerTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 21572b1c84d..c225ea8e718 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
@@ -71,7 +71,7 @@ public class SplitFetcherManagerTest {
.hasRootCauseMessage("Artificial exception on closing the
split reader.");
}
- @Test(timeout = 30000)
+ @Test
public void testCloseCleansUpPreviouslyClosedFetcher() throws Exception {
final String splitId = "testSplit";
// Set the queue capacity to 1 to make sure in this case the
@@ -94,7 +94,7 @@ public class SplitFetcherManagerTest {
},
"The idle fetcher should have been removed.");
// Now close the fetcher manager. The fetcher manager closing should
not block.
- fetcherManager.close(60_000);
+ fetcherManager.close(Long.MAX_VALUE);
}
@Test
