This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 9c558bc81109e4c1116b6f1ad44d2abc29e095bb Author: Stephan Ewen <[email protected]> AuthorDate: Tue Sep 29 22:25:37 2020 +0200 [refactor][tests] Move some source test utils from flink-connector-base to flink-core This makes them reusable in unit tests for simple sources that are implemented in flink-core --- .../flink/connector/base/source/reader/SourceReaderBaseTest.java | 4 ++-- .../flink/api/connector/source}/mocks/TestingReaderContext.java | 2 +- .../apache/flink/api/connector/source}/mocks/TestingReaderOutput.java | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) 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 ce32521..6396b2e 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 @@ -21,12 +21,12 @@ package org.apache.flink.connector.base.source.reader; import org.apache.flink.api.connector.source.Boundedness; import org.apache.flink.api.connector.source.SourceReader; import org.apache.flink.api.connector.source.mocks.MockSourceSplit; +import org.apache.flink.api.connector.source.mocks.TestingReaderContext; +import org.apache.flink.api.connector.source.mocks.TestingReaderOutput; import org.apache.flink.configuration.Configuration; import org.apache.flink.connector.base.source.reader.mocks.MockSourceReader; import org.apache.flink.connector.base.source.reader.mocks.MockSplitReader; import org.apache.flink.connector.base.source.reader.mocks.PassThroughRecordEmitter; -import org.apache.flink.connector.base.source.reader.mocks.TestingReaderContext; -import org.apache.flink.connector.base.source.reader.mocks.TestingReaderOutput; import org.apache.flink.connector.base.source.reader.mocks.TestingRecordsWithSplitIds; import org.apache.flink.connector.base.source.reader.mocks.TestingSourceSplit; import org.apache.flink.connector.base.source.reader.mocks.TestingSplitReader; diff --git a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/mocks/TestingReaderContext.java b/flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/TestingReaderContext.java similarity index 97% rename from flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/mocks/TestingReaderContext.java rename to flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/TestingReaderContext.java index 5bb9b59..cee4654 100644 --- a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/mocks/TestingReaderContext.java +++ b/flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/TestingReaderContext.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.connector.base.source.reader.mocks; +package org.apache.flink.api.connector.source.mocks; import org.apache.flink.api.connector.source.SourceEvent; import org.apache.flink.api.connector.source.SourceReaderContext; diff --git a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/mocks/TestingReaderOutput.java b/flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/TestingReaderOutput.java similarity index 96% rename from flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/mocks/TestingReaderOutput.java rename to flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/TestingReaderOutput.java index 4483819..1847cc4 100644 --- a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/mocks/TestingReaderOutput.java +++ b/flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/TestingReaderOutput.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.connector.base.source.reader.mocks; +package org.apache.flink.api.connector.source.mocks; import org.apache.flink.api.common.eventtime.Watermark; import org.apache.flink.api.connector.source.ReaderOutput;
