This is an automated email from the ASF dual-hosted git repository. jark pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from d3c3909 [FLINK-17449][sql-parser-hive] Implement ADD/DROP partitions add 83ae463 [hotfix][table-common] Add validateExcept() to FactoryUtil add 10a65ed [hotfix][kafka] Make FlinkKafkaConsumerBase#setStartFromTimestamp to be public add ca46672 [FLINK-17026][kafka] Introduce a new Kafka connect or with new property keys No new revisions were added by this update. Summary of changes: .../flink-connector-kafka-0.10/pom.xml | 17 + .../connectors/kafka/FlinkKafkaConsumer010.java | 11 - .../kafka/table/Kafka010DynamicSink.java | 81 +++++ .../kafka/table/Kafka010DynamicSource.java | 98 +++++ .../kafka/table/Kafka010DynamicTableFactory.java | 82 +++++ .../org.apache.flink.table.factories.Factory | 16 + .../table/Kafka010DynamicTableFactoryTest.java | 93 +++++ .../kafka/{ => table}/Kafka010TableITCase.java | 7 +- .../flink-connector-kafka-0.11/pom.xml | 9 + .../kafka/table/Kafka011DynamicSink.java | 82 +++++ .../kafka/table/Kafka011DynamicSource.java | 98 +++++ .../kafka/table/Kafka011DynamicTableFactory.java | 79 +++++ .../org.apache.flink.table.factories.Factory | 16 + .../table/Kafka011DynamicTableFactoryTest.java | 93 +++++ .../kafka/{ => table}/Kafka011TableITCase.java | 7 +- .../connectors/kafka/FlinkKafkaConsumerBase.java | 6 +- .../kafka/table/KafkaDynamicSinkBase.java | 133 +++++++ .../kafka/table/KafkaDynamicSourceBase.java | 214 +++++++++++ .../kafka/table/KafkaDynamicTableFactoryBase.java | 172 +++++++++ .../connectors/kafka/table/KafkaOptions.java | 370 +++++++++++++++++++ .../table/KafkaDynamicTableFactoryTestBase.java | 393 +++++++++++++++++++++ .../kafka/{ => table}/KafkaTableTestBase.java | 142 ++++---- flink-connectors/flink-connector-kafka/pom.xml | 9 + .../connectors/kafka/FlinkKafkaConsumer.java | 11 - .../connectors/kafka/table/KafkaDynamicSink.java | 81 +++++ .../connectors/kafka/table/KafkaDynamicSource.java | 95 +++++ .../kafka/table/KafkaDynamicTableFactory.java | 78 ++++ .../org.apache.flink.table.factories.Factory | 16 + .../kafka/table/KafkaDynamicTableFactoryTest.java | 92 +++++ .../kafka/{ => table}/KafkaTableITCase.java | 7 +- .../apache/flink/table/factories/FactoryUtil.java | 21 ++ .../flink/table/factories/TestFormatFactory.java | 4 +- 32 files changed, 2537 insertions(+), 96 deletions(-) create mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicSink.java create mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicSource.java create mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicTableFactory.java create mode 100644 flink-connectors/flink-connector-kafka-0.10/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory create mode 100644 flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicTableFactoryTest.java rename flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/{ => table}/Kafka010TableITCase.java (87%) create mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicSink.java create mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicSource.java create mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicTableFactory.java create mode 100644 flink-connectors/flink-connector-kafka-0.11/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory create mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicTableFactoryTest.java rename flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/{ => table}/Kafka011TableITCase.java (87%) create mode 100644 flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSinkBase.java create mode 100644 flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSourceBase.java create mode 100644 flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryBase.java create mode 100644 flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaOptions.java create mode 100644 flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryTestBase.java rename flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/{ => table}/KafkaTableTestBase.java (62%) create mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java create mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java create mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java create mode 100644 flink-connectors/flink-connector-kafka/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory create mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryTest.java rename flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/{ => table}/KafkaTableITCase.java (87%)