This is an automated email from the ASF dual-hosted git repository.
leonard pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from d09bf45 [FLINK-25277][flink-runtime] synchronize termination and
release of containers in YARNResourceManagerDriver
add 6b227b8 [FLINK-25287][connectors/testing-framework] Refactor
connector testing framework interfaces for more scenarios
add 8babbb0 [FLINK-25287][connectors/kafka] Use connector testing
framework for Kafka tests
add 6332c69 [FLINK-25287][connectors/pulsar] Use connector testing
framework interface for Pulsar tests
add d864ce3 [FLINK-25287][formats/avro] Use connector testing framework
interface for Avro format IT case
add 0dd661f [hotfix][connectors] Improve the typo and code style
add 0b35756 [FLINK-25712][connectors/testing-framework] Merge
flink-connector-testing module to flink-connector-test-utils module
No new revisions were added by this update.
Summary of changes:
.../flink-connector-elasticsearch-base/pom.xml | 2 +-
.../sink/ElasticsearchSinkBaseITCase.java | 2 +-
.../sink/ElasticsearchSinkBuilderBaseTest.java | 2 +-
.../sink/ElasticsearchWriterITCase.java | 2 +-
.../table/ElasticsearchDynamicSinkBaseITCase.java | 2 +-
.../ElasticsearchDynamicSinkFactoryBaseTest.java | 2 +-
.../flink-connector-elasticsearch6/pom.xml | 2 +-
.../flink-connector-elasticsearch7/pom.xml | 2 +-
flink-connectors/flink-connector-kafka/pom.xml | 6 -
.../connector/kafka/sink/KafkaCommitterTest.java | 2 +-
.../connector/kafka/source/KafkaSourceITCase.java | 33 +-
.../KafkaMultipleTopicExternalContext.java | 124 ------
.../kafka/testutils/KafkaPartitionDataWriter.java | 12 +-
.../testutils/KafkaSingleTopicExternalContext.java | 241 ------------
.../testutils/KafkaSourceExternalContext.java | 240 ++++++++++++
.../KafkaSourceExternalContextFactory.java | 59 +++
flink-connectors/flink-connector-kinesis/pom.xml | 2 +-
.../kinesis/util/UniformShardAssignerTest.java | 2 +-
flink-connectors/flink-connector-pulsar/pom.xml | 7 -
.../pulsar/source/PulsarSourceITCase.java | 19 +-
.../reader/source/PulsarSourceReaderTestBase.java | 2 +-
.../split/PulsarPartitionSplitReaderTestBase.java | 2 +-
.../testutils/PulsarPartitionDataWriter.java | 8 +-
.../pulsar/testutils/PulsarTestContext.java | 16 +-
.../pulsar/testutils/PulsarTestContextFactory.java | 6 +-
.../pulsar/testutils/PulsarTestEnvironment.java | 10 +-
.../pulsar/testutils/PulsarTestSuiteBase.java | 2 +-
.../cases/MultipleTopicConsumingContext.java | 13 +-
.../cases/MultipleTopicTemplateContext.java | 34 +-
.../cases/SingleTopicConsumingContext.java | 34 +-
.../testutils/runtime/PulsarRuntimeOperator.java | 2 +-
.../flink-end-to-end-tests-common-kafka/pom.xml | 2 +-
.../flink/tests/util/kafka/KafkaSourceE2ECase.java | 52 ++-
.../flink-end-to-end-tests-common/pom.xml | 2 +-
.../util/flink/FlinkContainerTestEnvironment.java | 74 ++--
.../util/pulsar/PulsarSourceOrderedE2ECase.java | 14 +-
.../util/pulsar/PulsarSourceUnorderedE2ECase.java | 14 +-
.../pulsar/cases/ExclusiveSubscriptionContext.java | 15 +-
.../pulsar/cases/FailoverSubscriptionContext.java | 15 +-
.../pulsar/cases/KeySharedSubscriptionContext.java | 34 +-
.../pulsar/cases/SharedSubscriptionContext.java | 30 +-
.../FlinkContainerWithPulsarEnvironment.java | 7 +-
.../common/KeyedPulsarPartitionDataWriter.java | 7 +-
.../common/UnorderedSourceTestSuiteBase.java | 40 +-
flink-formats/flink-avro/pom.xml | 2 +-
.../flink/formats/avro/AvroBulkFormatITCase.java | 100 ++---
.../flink-connector-test-utils/pom.xml | 29 ++
.../flink/connector/testframe}/TestResource.java | 10 +-
.../environment/ClusterControllable.java | 20 +-
.../environment/MiniClusterTestEnvironment.java | 33 +-
.../testframe/environment/TestEnvironment.java | 78 ++++
.../environment/TestEnvironmentSettings.java | 82 ++++
.../DefaultContainerizedExternalSystem.java | 4 +-
.../testframe/external/ExternalContext.java} | 20 +-
.../external/ExternalContextFactory.java} | 14 +-
.../external/ExternalSystemDataReader.java} | 25 +-
.../external/ExternalSystemSplitDataWriter.java} | 10 +-
.../sink/DataStreamSinkExternalContext.java | 64 +++
.../external/sink/TableSinkExternalContext.java | 48 +++
.../external/sink/TestingSinkSettings.java | 60 +++
.../source/DataStreamSourceExternalContext.java | 72 ++++
.../source/TableSourceExternalContext.java | 48 +++
.../external/source/TestingSourceSettings.java | 75 ++++
.../testframe/junit/annotations/TestContext.java} | 9 +-
.../testframe}/junit/annotations/TestEnv.java | 4 +-
.../junit/annotations/TestExternalSystem.java} | 4 +-
.../extensions/ConnectorTestingExtension.java | 66 ++--
.../TestCaseInvocationContextProvider.java | 39 +-
.../testframe/testsuites/SourceTestSuiteBase.java | 433 +++++++++++++++++++++
.../testframe}/utils/TestDataMatchers.java | 2 +-
.../flink-connector-testing/README.md | 44 ---
.../flink-connector-testing/pom.xml | 79 ----
.../environment/RemoteClusterTestEnvironment.java | 71 ----
.../test/common/external/ExternalContext.java | 79 ----
.../junit/extensions/TestLoggerExtension.java | 83 ----
.../common/testsuites/SourceTestSuiteBase.java | 318 ---------------
.../test/common/utils/TestDataMatchersTest.java | 218 -----------
flink-test-utils-parent/pom.xml | 1 -
78 files changed, 1844 insertions(+), 1598 deletions(-)
delete mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaMultipleTopicExternalContext.java
delete mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaSingleTopicExternalContext.java
create mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaSourceExternalContext.java
create mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaSourceExternalContextFactory.java
rename
flink-test-utils-parent/{flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common
=>
flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe}/TestResource.java
(84%)
rename
flink-test-utils-parent/{flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common
=>
flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe}/environment/ClusterControllable.java
(66%)
rename
flink-test-utils-parent/{flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common
=>
flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe}/environment/MiniClusterTestEnvironment.java
(83%)
create mode 100644
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/environment/TestEnvironment.java
create mode 100644
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/environment/TestEnvironmentSettings.java
rename
flink-test-utils-parent/{flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common
=>
flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe}/external/DefaultContainerizedExternalSystem.java
(96%)
copy
flink-test-utils-parent/{flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/external/SourceSplitDataWriter.java
=>
flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/external/ExternalContext.java}
(53%)
copy
flink-test-utils-parent/{flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/environment/TestEnvironment.java
=>
flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/external/ExternalContextFactory.java}
(63%)
rename
flink-test-utils-parent/{flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/environment/TestEnvironment.java
=>
flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/external/ExternalSystemDataReader.java}
(57%)
rename
flink-test-utils-parent/{flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/external/SourceSplitDataWriter.java
=>
flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/external/ExternalSystemSplitDataWriter.java}
(80%)
create mode 100644
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/external/sink/DataStreamSinkExternalContext.java
create mode 100644
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/external/sink/TableSinkExternalContext.java
create mode 100644
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/external/sink/TestingSinkSettings.java
create mode 100644
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/external/source/DataStreamSourceExternalContext.java
create mode 100644
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/external/source/TableSourceExternalContext.java
create mode 100644
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/external/source/TestingSourceSettings.java
rename
flink-test-utils-parent/{flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/junit/annotations/ExternalContextFactory.java
=>
flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/junit/annotations/TestContext.java}
(85%)
rename
flink-test-utils-parent/{flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common
=>
flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe}/junit/annotations/TestEnv.java
(91%)
rename
flink-test-utils-parent/{flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/junit/annotations/ExternalSystem.java
=>
flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/junit/annotations/TestExternalSystem.java}
(93%)
rename
flink-test-utils-parent/{flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common
=>
flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe}/junit/extensions/ConnectorTestingExtension.java
(70%)
rename
flink-test-utils-parent/{flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common
=>
flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe}/junit/extensions/TestCaseInvocationContextProvider.java
(82%)
create mode 100644
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java
rename
flink-test-utils-parent/{flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common
=>
flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe}/utils/TestDataMatchers.java
(99%)
delete mode 100644 flink-test-utils-parent/flink-connector-testing/README.md
delete mode 100644 flink-test-utils-parent/flink-connector-testing/pom.xml
delete mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/environment/RemoteClusterTestEnvironment.java
delete mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/external/ExternalContext.java
delete mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/junit/extensions/TestLoggerExtension.java
delete mode 100644
flink-test-utils-parent/flink-connector-testing/src/main/java/org/apache/flink/connectors/test/common/testsuites/SourceTestSuiteBase.java
delete mode 100644
flink-test-utils-parent/flink-connector-testing/src/test/java/org/apache/flink/connectors/test/common/utils/TestDataMatchersTest.java
