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 7b04b29 [FLINK-19706][table-runtime] Add WARN logs when hive table
partition has existed before commit
add 909e747 [hotfix][table-common] Avoid unnecessary casting when
creating type information in sources and sinks
add b6e5a9c [hotfix][connector-kafka] Merge KafkaITCase and
KafkaTableTestBase
add a59fa70 [hotfix][table-common] Add a new Row.deepEquals for all
conversion classes
add d21f5d9 [FLINK-19275][connector-kafka] Support reading and writing
Kafka metadata
No new revisions were added by this update.
Summary of changes:
.../connector/jdbc/table/JdbcDynamicTableSink.java | 5 +-
.../jdbc/table/JdbcDynamicTableSource.java | 7 +-
.../table/DynamicKafkaDeserializationSchema.java | 139 +++++++
.../table/DynamicKafkaSerializationSchema.java | 160 ++++++++
.../connectors/kafka/table/KafkaDynamicSink.java | 183 ++++++++-
.../connectors/kafka/table/KafkaDynamicSource.java | 158 +++++++-
.../kafka/table/KafkaDynamicTableFactory.java | 19 +-
.../connectors/kafka/table/KafkaTableITCase.java | 436 ++++++++++++++++++++-
.../connectors/kafka/table/KafkaTableTestBase.java | 358 -----------------
.../src/main/java/org/apache/flink/types/Row.java | 122 ++++++
.../test/java/org/apache/flink/types/RowTest.java | 95 +++++
.../java/connectors/ChangelogCsvFormat.java | 3 +-
.../confluent/RegistryAvroFormatFactory.java | 2 +-
.../flink/formats/avro/AvroFormatFactory.java | 2 +-
.../apache/flink/formats/csv/CsvFormatFactory.java | 3 +-
.../flink/formats/json/JsonFormatFactory.java | 3 +-
.../formats/json/canal/CanalJsonFormatFactory.java | 3 +-
.../json/debezium/DebeziumJsonFormatFactory.java | 3 +-
.../json/maxwell/MaxwellJsonFormatFactory.java | 3 +-
.../table/connector/sink/DynamicTableSink.java | 2 +-
.../table/connector/source/DynamicTableSource.java | 2 +-
.../flink/table/utils/TableTestMatchers.java | 71 ++++
.../planner/factories/TestValuesTableFactory.java | 5 +-
23 files changed, 1350 insertions(+), 434 deletions(-)
create mode 100644
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java
create mode 100644
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaSerializationSchema.java
delete mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableTestBase.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/TableTestMatchers.java
