This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from fada6fb [FLINK-18820] Emit MAX_WATERMARK at the end in SourceOperator
add f570d04 [FLINK-19779][avro] Remove the "record_" field name prefix
for Avro format deserialization
add 146269d [FLINK-19786][avro] Fix the nullability and precision for
Avro format deserialization
No new revisions were added by this update.
Summary of changes:
.../connector/hbase/util/HBaseTableSchema.java | 31 ++-
.../flink/connectors/hive/HiveTableSinkITCase.java | 2 +-
.../RegistryAvroRowDataSeDeSchemaTest.java | 5 +-
.../avro/typeutils/AvroSchemaConverter.java | 106 +++++---
.../avro/AvroRowDataDeSerializationSchemaTest.java | 10 +-
.../avro/typeutils/AvroSchemaConverterTest.java | 287 +++++++++++++++++++--
flink-python/pyflink/table/table_environment.py | 2 +-
.../pyflink/table/tests/test_pandas_conversion.py | 2 +-
.../pyflink/table/tests/test_table_schema.py | 3 +-
.../client/gateway/utils/SimpleCatalogFactory.java | 4 +-
.../org/apache/flink/table/api/TableSchema.java | 9 +-
.../table/factories/FileSystemFormatFactory.java | 2 +
.../apache/flink/table/sources/TableSource.java | 2 +-
.../apache/flink/table/types/logical/RowType.java | 6 +-
.../apache/flink/table/api/TableSchemaTest.java | 46 +++-
.../plan/nodes/dataset/BatchTableSourceScan.scala | 3 +-
.../nodes/datastream/StreamTableSourceScan.scala | 3 +-
.../table/filesystem/FileSystemTableSource.java | 3 +-
18 files changed, 442 insertions(+), 84 deletions(-)
