This is an automated email from the ASF dual-hosted git repository.
arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 091a201 [FLINK-14482][rocksdb] Bump FRocksDB version to 6.20.3
new 4fd3323 [hotfix][test/testcontainers] Use Testcontainer BOM to manage
versions in the project
new 613a824 [FLINK-19554][connector/testing-framework] Basic abstractions
of connector testing framework
new 43066fe [FLINK-19554][testutil/container] Support TM restarting in
FlinkContainer and network accessibility from other containers
new b9e1e4d [FLINK-19554][connector/testing-framework] Implementations of
TestEnvironment
new 249b281 [FLINK-19554][connector/testing-framework] Connector testing
framework utilities based on JUnit 5
new b6bf1aa [FLINK-19554][connector/testing-framework] Base test class
for source with fundamental test cases
new adee561 [FLINK-19554][connector/testing-framework] KafkaSource IT and
E2E case based on connector testing framework
The 7 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink-connector-elasticsearch6/pom.xml | 1 -
.../flink-connector-elasticsearch7/pom.xml | 1 -
flink-connectors/flink-connector-jdbc/pom.xml | 7 +-
flink-connectors/flink-connector-kafka/pom.xml | 13 +-
.../connector/kafka/source/KafkaSourceITCase.java | 313 ++++++++++++---------
.../source/enumerator/KafkaEnumeratorTest.java | 2 +-
.../initializer/OffsetsInitializerTest.java | 2 +-
.../enumerator/subscriber/KafkaSubscriberTest.java | 2 +-
.../reader/KafkaPartitionSplitReaderTest.java | 2 +-
.../kafka/source/reader/KafkaSourceReaderTest.java | 2 +-
.../KafkaMultipleTopicExternalContext.java | 124 ++++++++
.../source/testutils/KafkaPartitionDataWriter.java | 60 ++++
.../testutils/KafkaSingleTopicExternalContext.java | 242 ++++++++++++++++
.../source/{ => testutils}/KafkaSourceTestEnv.java | 2 +-
flink-connectors/flink-connector-kinesis/pom.xml | 1 -
flink-connectors/flink-connector-rabbitmq/pom.xml | 1 -
.../flink-end-to-end-tests-common-kafka/pom.xml | 30 +-
.../flink/tests/util/kafka/KafkaSourceE2ECase.java | 69 +++++
.../flink-end-to-end-tests-common/pom.xml | 6 +-
.../flink/tests/util/flink/FlinkContainer.java | 99 ++++++-
.../util/flink/FlinkContainerTestEnvironment.java | 121 ++++++++
.../flink-streaming-kinesis-test/pom.xml | 17 ++
.../flink/runtime/testutils/CommonTestUtils.java | 41 +++
.../flink-connector-testing/README.md | 44 +++
.../flink-connector-testing}/pom.xml | 59 ++--
.../flink/connectors/test/common/TestResource.java | 53 ++++
.../common/environment/ClusterControllable.java | 33 +++
.../environment/MiniClusterTestEnvironment.java | 135 +++++++++
.../environment/RemoteClusterTestEnvironment.java | 71 +++++
.../test/common/environment/TestEnvironment.java | 35 +++
.../DefaultContainerizedExternalSystem.java | 108 +++++++
.../test/common/external/ExternalContext.java | 75 +++++
.../common/external/SourceSplitDataWriter.java | 34 +++
.../junit/annotations/ExternalContextFactory.java | 43 +++
.../common/junit/annotations/ExternalSystem.java | 39 +++
.../test/common/junit/annotations/TestEnv.java | 40 +++
.../extensions/ConnectorTestingExtension.java | 144 ++++++++++
.../TestCaseInvocationContextProvider.java | 203 +++++++++++++
.../junit/extensions/TestLoggerExtension.java | 83 ++++++
.../common/testsuites/SourceTestSuiteBase.java | 299 ++++++++++++++++++++
.../test/common/utils/TestDataMatchers.java | 246 ++++++++++++++++
.../test/common/utils/IteratorWithCurrentTest.java | 77 +++++
.../test/common/utils/TestDataMatchersTest.java | 166 +++++++++++
flink-test-utils-parent/pom.xml | 1 +
pom.xml | 8 +
.../modules-skipping-deployment.modulelist | 1 +
46 files changed, 2959 insertions(+), 196 deletions(-)
create mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/testutils/KafkaMultipleTopicExternalContext.java
create mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/testutils/KafkaPartitionDataWriter.java
create mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/testutils/KafkaSingleTopicExternalContext.java
rename
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/{
=> testutils}/KafkaSourceTestEnv.java (99%)
create mode 100644
flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSourceE2ECase.java
create mode 100644
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/FlinkContainerTestEnvironment.java
create mode 100644 flink-test-utils-parent/flink-connector-testing/README.md
copy {flink-connectors/flink-connector-rabbitmq =>
flink-test-utils-parent/flink-connector-testing}/pom.xml (62%)
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/TestResource.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/environment/ClusterControllable.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/environment/MiniClusterTestEnvironment.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/environment/RemoteClusterTestEnvironment.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/environment/TestEnvironment.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/external/DefaultContainerizedExternalSystem.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/external/ExternalContext.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/external/SourceSplitDataWriter.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/junit/annotations/ExternalContextFactory.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/junit/annotations/ExternalSystem.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/junit/annotations/TestEnv.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/junit/extensions/ConnectorTestingExtension.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/junit/extensions/TestCaseInvocationContextProvider.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/junit/extensions/TestLoggerExtension.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/testsuites/SourceTestSuiteBase.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/utils/TestDataMatchers.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/test/java/org/apache/flink/connectors/test/common/utils/IteratorWithCurrentTest.java
create mode 100644
flink-test-utils-parent/flink-connector-testing/src/test/java/org/apache/flink/connectors/test/common/utils/TestDataMatchersTest.java
