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 674817c [FLINK-18067][yarn] Change default value of
yarnMinAllocationMB from zero to DEFAULT_RM_SCHEDULER_MINIMUM_ALLOCATION_MB
add 8f858f3 [FLINK-18073][avro] Fix AvroRowDataSerializationSchema is not
serializable
add a479aee [hotfix][avro] Fix AvroRowSerializationSchema doesn't support
TIMESTAMP type
add 88871b2 [FLINK-18029][kafka] Add more ITCases for Kafka with new
formats (avro, csv, json)
No new revisions were added by this update.
Summary of changes:
.../flink-connector-kafka-0.10/pom.xml | 13 +++
.../flink-connector-kafka-0.11/pom.xml | 13 +++
.../connectors/kafka/table/KafkaTableTestBase.java | 81 ++++++++++++++-----
flink-connectors/flink-connector-kafka/pom.xml | 13 +++
.../formats/avro/AvroFileSystemFormatFactory.java | 3 +-
.../avro/AvroRowDataSerializationSchema.java | 92 +++++++++++++++++-----
.../formats/avro/AvroRowSerializationSchema.java | 9 +++
.../avro/typeutils/AvroSchemaConverter.java | 23 +++---
.../avro/typeutils/AvroSchemaConverterTest.java | 42 ++++++++++
9 files changed, 236 insertions(+), 53 deletions(-)
