This is an automated email from the ASF dual-hosted git repository.
mbalassi pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 8990822bd77 [FLINK-31273][table-planner] Fix left join with IS_NULL
filter be wrongly pushed down and get wrong join results
add e818c11d104 [FLINK-31085][formats] Add schema option to confluent
registry avro formats
No new revisions were added by this update.
Summary of changes:
.../connectors/table/formats/avro-confluent.md | 7 +
.../docs/connectors/table/formats/debezium.md | 7 +
.../connectors/table/formats/avro-confluent.md | 8 ++
.../docs/connectors/table/formats/debezium.md | 7 +
.../kafka/table/KafkaDynamicTableFactoryTest.java | 2 +-
.../confluent/AvroConfluentFormatOptions.java | 12 ++
.../confluent/RegistryAvroFormatFactory.java | 45 ++++++-
.../DebeziumAvroDeserializationSchema.java | 15 ++-
.../debezium/DebeziumAvroFormatFactory.java | 32 ++++-
.../debezium/DebeziumAvroSerializationSchema.java | 15 ++-
.../confluent/RegistryAvroFormatFactoryTest.java | 54 +++++++-
.../debezium/DebeziumAvroFormatFactoryTest.java | 144 ++++++++++++++++++++-
.../avro/AvroRowDataSerializationSchema.java | 6 +-
.../formats/avro/AvroSerializationSchema.java | 8 ++
.../avro/AvroRowDataDeSerializationSchemaTest.java | 83 ++++++++++++
.../formats/avro/AvroSerializationSchemaTest.java | 18 +++
16 files changed, 438 insertions(+), 25 deletions(-)
