This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5ffdc4e [FLINK-19619][e2e] Pin CloudSDK version to have access to
pubsub emulator in test
new a87407e [FLINK-19672][connector-kafka] Merge connector-kafka-base and
connector-kafka
new 9eb8beb [FLINK-19672][connector-kafka] Merge internal and internals
package
new c320e99 [FLINK-19672][connector-kafka] Update Kafka table sources and
sinks
new 93c0855 [hotfix][connector-kafka] Deprecate old Kafka table sources
and sinks
The 4 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-kafka-base/pom.xml | 287 ----------
.../kafka/table/KafkaDynamicSinkBase.java | 141 -----
.../kafka/table/KafkaDynamicSourceBase.java | 239 --------
.../kafka/table/KafkaDynamicTableFactoryBase.java | 200 -------
.../table/KafkaDynamicTableFactoryTestBase.java | 606 ---------------------
.../kafka/testutils/ZooKeeperStringSerializer.java | 49 --
.../src/test/resources/log4j2-test.properties | 38 --
flink-connectors/flink-connector-kafka/pom.xml | 26 -
.../connectors/kafka/FlinkKafkaConsumer.java | 4 +-
.../connectors/kafka/FlinkKafkaConsumerBase.java | 0
.../connectors/kafka/FlinkKafkaProducer.java | 6 +-
.../connectors/kafka/FlinkKafkaProducerBase.java | 0
.../connectors/kafka/KafkaContextAware.java | 0
.../kafka/KafkaDeserializationSchema.java | 0
.../connectors/kafka/KafkaSerializationSchema.java | 0
.../streaming/connectors/kafka/KafkaTableSink.java | 5 +
.../connectors/kafka/KafkaTableSinkBase.java | 5 +
.../connectors/kafka/KafkaTableSource.java | 5 +
.../connectors/kafka/KafkaTableSourceBase.java | 5 +
.../kafka/KafkaTableSourceSinkFactory.java | 4 +
.../kafka/KafkaTableSourceSinkFactoryBase.java | 4 +
.../connectors/kafka/config/OffsetCommitMode.java | 0
.../connectors/kafka/config/OffsetCommitModes.java | 0
.../connectors/kafka/config/StartupMode.java | 0
.../kafka/internals/AbstractFetcher.java | 0
.../internals/AbstractPartitionDiscoverer.java | 0
.../kafka/internals/ClosableBlockingQueue.java | 0
.../connectors/kafka/internals/ExceptionProxy.java | 0
.../FlinkKafkaInternalProducer.java | 2 +-
.../kafka/{internal => internals}/Handover.java | 2 +-
.../kafka/internals/KafkaCommitCallback.java | 0
.../KafkaConsumerThread.java | 6 +-
.../KafkaDeserializationSchemaWrapper.java | 0
.../{internal => internals}/KafkaFetcher.java | 6 +-
.../KafkaPartitionDiscoverer.java | 5 +-
.../internals/KafkaSerializationSchemaWrapper.java | 0
.../KafkaShuffleFetcher.java | 4 +-
.../kafka/internals/KafkaTopicPartition.java | 0
.../internals/KafkaTopicPartitionAssigner.java | 0
.../kafka/internals/KafkaTopicPartitionLeader.java | 0
.../kafka/internals/KafkaTopicPartitionState.java | 0
.../KafkaTopicPartitionStateSentinel.java | 0
...aTopicPartitionStateWithWatermarkGenerator.java | 0
.../kafka/internals/KafkaTopicsDescriptor.java | 0
.../internals/KeyedSerializationSchemaWrapper.java | 0
.../SourceContextWatermarkOutputAdapter.java | 0
.../TransactionalIdsGenerator.java | 2 +-
.../metrics/KafkaConsumerMetricConstants.java | 0
.../metrics/KafkaMetricMutableWrapper.java | 2 +-
.../internals/metrics/KafkaMetricWrapper.java | 0
.../kafka/partitioner/FlinkFixedPartitioner.java | 0
.../kafka/partitioner/FlinkKafkaPartitioner.java | 0
.../kafka/shuffle/FlinkKafkaShuffleConsumer.java | 2 +-
.../connectors/kafka/table/KafkaDynamicSink.java | 122 +++--
.../connectors/kafka/table/KafkaDynamicSource.java | 188 +++++--
.../kafka/table/KafkaDynamicTableFactory.java | 153 +++++-
.../connectors/kafka/table/KafkaOptions.java | 2 +-
.../connectors/kafka/table/KafkaSinkSemantic.java | 0
.../JSONKeyValueDeserializationSchema.java | 0
.../serialization/KeyedDeserializationSchema.java | 0
.../serialization/KeyedSerializationSchema.java | 0
...TypeInformationKeyValueSerializationSchema.java | 0
.../org/apache/flink/table/descriptors/Kafka.java | 0
.../flink/table/descriptors/KafkaValidator.java | 0
.../kafka/FlinkFixedPartitionerTest.java | 0
.../kafka/FlinkKafkaConsumerBaseMigrationTest.java | 0
.../kafka/FlinkKafkaConsumerBaseTest.java | 0
.../kafka/FlinkKafkaInternalProducerITCase.java | 2 +-
.../kafka/FlinkKafkaProducerBaseTest.java | 0
.../JSONKeyValueDeserializationSchemaTest.java | 0
.../connectors/kafka/KafkaConsumerTestBase.java | 5 +-
.../connectors/kafka/KafkaMigrationTestBase.java | 0
.../connectors/kafka/KafkaProducerTestBase.java | 0
.../kafka/KafkaSerializerUpgradeTest.java | 2 +-
.../kafka/KafkaShortRetentionTestBase.java | 0
.../kafka/KafkaTableSourceSinkFactoryTestBase.java | 0
.../streaming/connectors/kafka/KafkaTestBase.java | 0
.../connectors/kafka/KafkaTestBaseWithFlink.java | 0
.../connectors/kafka/KafkaTestEnvironment.java | 0
.../kafka/internals/AbstractFetcherTest.java | 0
.../internals/AbstractFetcherWatermarksTest.java | 0
.../internals/AbstractPartitionDiscovererTest.java | 0
.../kafka/internals/ClosableBlockingQueueTest.java | 0
.../kafka/internals/KafkaTopicPartitionTest.java | 0
.../kafka/internals/KafkaTopicsDescriptorTest.java | 0
.../kafka/shuffle/KafkaShuffleITCase.java | 8 +-
.../kafka/table/KafkaDynamicTableFactoryTest.java | 553 ++++++++++++++++++-
.../connectors/kafka/table/KafkaTableTestBase.java | 0
.../kafka/testutils/ClusterCommunicationUtils.java | 0
.../connectors/kafka/testutils/DataGenerators.java | 0
.../kafka/testutils/FailingIdentityMapper.java | 0
.../testutils/FakeStandardProducerConfig.java | 0
.../connectors/kafka/testutils/IntegerSource.java | 0
.../kafka/testutils/PartitionValidatingMapper.java | 0
.../kafka/testutils/TestPartitionDiscoverer.java | 0
.../kafka/testutils/TestSourceContext.java | 0
.../kafka/testutils/ThrottledMapper.java | 0
.../kafka/testutils/Tuple2FlinkPartitioner.java | 0
.../kafka/testutils/ValidatingExactlyOnceSink.java | 0
.../apache/flink/table/descriptors/KafkaTest.java | 0
.../table/descriptors/KafkaValidatorTest.java | 0
...r-migration-test-flink1.10-empty-state-snapshot | Bin
...afka-consumer-migration-test-flink1.10-snapshot | Bin
...r-migration-test-flink1.11-empty-state-snapshot | Bin
...afka-consumer-migration-test-flink1.11-snapshot | Bin
...er-migration-test-flink1.4-empty-state-snapshot | Bin
...kafka-consumer-migration-test-flink1.4-snapshot | Bin
...er-migration-test-flink1.5-empty-state-snapshot | Bin
...kafka-consumer-migration-test-flink1.5-snapshot | Bin
...er-migration-test-flink1.6-empty-state-snapshot | Bin
...kafka-consumer-migration-test-flink1.6-snapshot | Bin
...er-migration-test-flink1.7-empty-state-snapshot | Bin
...kafka-consumer-migration-test-flink1.7-snapshot | Bin
...er-migration-test-flink1.8-empty-state-snapshot | Bin
...kafka-consumer-migration-test-flink1.8-snapshot | Bin
...er-migration-test-flink1.9-empty-state-snapshot | Bin
...kafka-consumer-migration-test-flink1.9-snapshot | Bin
flink-connectors/flink-sql-connector-kafka/pom.xml | 1 -
flink-connectors/pom.xml | 1 -
.../pyflink/table/tests/test_descriptor.py | 2 +-
tools/ci/stage.sh | 1 -
121 files changed, 948 insertions(+), 1747 deletions(-)
delete mode 100644 flink-connectors/flink-connector-kafka-base/pom.xml
delete mode 100644
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSinkBase.java
delete mode 100644
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSourceBase.java
delete mode 100644
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryBase.java
delete mode 100644
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryTestBase.java
delete mode 100644
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/ZooKeeperStringSerializer.java
delete mode 100644
flink-connectors/flink-connector-kafka-base/src/test/resources/log4j2-test.properties
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaContextAware.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaDeserializationSchema.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaSerializationSchema.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkBase.java
(95%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceBase.java
(98%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactoryBase.java
(99%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/config/OffsetCommitMode.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/config/OffsetCommitModes.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/config/StartupMode.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractPartitionDiscoverer.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ExceptionProxy.java
(100%)
rename
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/{internal
=> internals}/FlinkKafkaInternalProducer.java (99%)
rename
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/{internal
=> internals}/Handover.java (99%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaCommitCallback.java
(100%)
rename
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/{internal
=> internals}/KafkaConsumerThread.java (97%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaDeserializationSchemaWrapper.java
(100%)
rename
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/{internal
=> internals}/KafkaFetcher.java (95%)
rename
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/{internal
=> internals}/KafkaPartitionDiscoverer.java (91%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaSerializationSchemaWrapper.java
(100%)
rename
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/{internal
=> internals}/KafkaShuffleFetcher.java (97%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartition.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionAssigner.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionLeader.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionState.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionStateSentinel.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionStateWithWatermarkGenerator.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicsDescriptor.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KeyedSerializationSchemaWrapper.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/SourceContextWatermarkOutputAdapter.java
(100%)
rename
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/{internal
=> internals}/TransactionalIdsGenerator.java (98%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaConsumerMetricConstants.java
(100%)
rename
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/{internal
=> internals}/metrics/KafkaMetricMutableWrapper.java (94%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricWrapper.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkKafkaPartitioner.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaOptions.java
(99%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaSinkSemantic.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/util/serialization/KeyedDeserializationSchema.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/util/serialization/KeyedSerializationSchema.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/streaming/util/serialization/TypeInformationKeyValueSerializationSchema.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/table/descriptors/Kafka.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/main/java/org/apache/flink/table/descriptors/KafkaValidator.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkFixedPartitionerTest.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseTest.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBaseTest.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/JSONKeyValueDeserializationSchemaTest.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
(99%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaMigrationTestBase.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaShortRetentionTestBase.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactoryTestBase.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBaseWithFlink.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironment.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcherTest.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcherWatermarksTest.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractPartitionDiscovererTest.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueueTest.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionTest.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicsDescriptorTest.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableTestBase.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/ClusterCommunicationUtils.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/DataGenerators.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/FailingIdentityMapper.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/FakeStandardProducerConfig.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/IntegerSource.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/PartitionValidatingMapper.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/TestPartitionDiscoverer.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/TestSourceContext.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/ThrottledMapper.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/Tuple2FlinkPartitioner.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/ValidatingExactlyOnceSink.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/table/descriptors/KafkaTest.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/java/org/apache/flink/table/descriptors/KafkaValidatorTest.java
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/resources/kafka-consumer-migration-test-flink1.10-empty-state-snapshot
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/resources/kafka-consumer-migration-test-flink1.10-snapshot
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/resources/kafka-consumer-migration-test-flink1.11-empty-state-snapshot
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/resources/kafka-consumer-migration-test-flink1.11-snapshot
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/resources/kafka-consumer-migration-test-flink1.4-empty-state-snapshot
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/resources/kafka-consumer-migration-test-flink1.4-snapshot
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/resources/kafka-consumer-migration-test-flink1.5-empty-state-snapshot
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/resources/kafka-consumer-migration-test-flink1.5-snapshot
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/resources/kafka-consumer-migration-test-flink1.6-empty-state-snapshot
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/resources/kafka-consumer-migration-test-flink1.6-snapshot
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/resources/kafka-consumer-migration-test-flink1.7-empty-state-snapshot
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/resources/kafka-consumer-migration-test-flink1.7-snapshot
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/resources/kafka-consumer-migration-test-flink1.8-empty-state-snapshot
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/resources/kafka-consumer-migration-test-flink1.8-snapshot
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/resources/kafka-consumer-migration-test-flink1.9-empty-state-snapshot
(100%)
rename flink-connectors/{flink-connector-kafka-base =>
flink-connector-kafka}/src/test/resources/kafka-consumer-migration-test-flink1.9-snapshot
(100%)
