Skip to content

Commit cc0a8b3

Browse files
authored
[FLINK-36292][Connectors/Common][test]: remove timeout to avoid timeout exception (apache#25371)
1 parent 84eab04 commit cc0a8b3

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherManagerTest.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ public void testCloseFetcherWithException() throws Exception {
7171
.hasRootCauseMessage("Artificial exception on closing the split reader.");
7272
}
7373

74-
@Test(timeout = 30000)
74+
@Test
7575
public void testCloseCleansUpPreviouslyClosedFetcher() throws Exception {
7676
final String splitId = "testSplit";
7777
// Set the queue capacity to 1 to make sure in this case the
@@ -94,7 +94,7 @@ public void testCloseCleansUpPreviouslyClosedFetcher() throws Exception {
9494
},
9595
"The idle fetcher should have been removed.");
9696
// Now close the fetcher manager. The fetcher manager closing should not block.
97-
fetcherManager.close(60_000);
97+
fetcherManager.close(Long.MAX_VALUE);
9898
}
9999

100100
@Test

0 commit comments

Comments
 (0)