This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 1958d8f3849ec533870c2e5ec2cd9ee3e508e425 Author: Jiangjie (Becket) Qin <[email protected]> AuthorDate: Thu Nov 12 18:46:29 2020 +0800 [minor] Fix the test name of SourceReaderBaseTest.testPollNextReturnMoreAvailableWhenAllSplitFetcherCloseWithLeftoverElementInQueue. --- .../apache/flink/connector/base/source/reader/SourceReaderBaseTest.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/SourceReaderBaseTest.java b/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/SourceReaderBaseTest.java index 9f7742017..3efe222 100644 --- a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/SourceReaderBaseTest.java +++ b/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/SourceReaderBaseTest.java @@ -198,7 +198,7 @@ public class SourceReaderBaseTest extends SourceReaderTestBase<MockSourceSplit> } @Test - public void pollNextReturnMoreAvailableWhenAllSplitFetcherCloseWithLeftoverElementInQueue() + public void testPollNextReturnMoreAvailableWhenAllSplitFetcherCloseWithLeftoverElementInQueue() throws Exception { FutureCompletingBlockingQueue<RecordsWithSplitIds<int[]>> elementsQueue =
