This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8e574f6 [hotfix] Rename
JobManagerProcessUtils#processSpecFromConfigWithFallbackForLegacyHeap to
processSpecFromConfigAndFallbackToNewOptIfLegacyHeapSet
add 965c101 [FLINK-11395][avro] Support for Avro StreamingFileSink
No new revisions were added by this update.
Summary of changes:
.../org/apache/flink/formats/avro/AvroBuilder.java | 19 +--
.../apache/flink/formats/avro/AvroBulkWriter.java} | 38 +++---
.../flink/formats/avro/AvroWriterFactory.java | 90 ++++++++++++++
.../org/apache/flink/formats/avro/AvroWriters.java | 104 ++++++++++++++++
.../formats/avro/AvroStreamingFileSinkITCase.java} | 131 +++++++++------------
5 files changed, 279 insertions(+), 103 deletions(-)
copy
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/conversion/HiveObjectConversion.java
=>
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroBuilder.java
(66%)
copy
flink-formats/{flink-compress/src/main/java/org/apache/flink/formats/compress/writers/HadoopCompressionBulkWriter.java
=> flink-avro/src/main/java/org/apache/flink/formats/avro/AvroBulkWriter.java}
(56%)
create mode 100644
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroWriterFactory.java
create mode 100644
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroWriters.java
copy
flink-formats/{flink-parquet/src/test/java/org/apache/flink/formats/parquet/avro/ParquetStreamingFileSinkITCase.java
=>
flink-avro/src/test/java/org/apache/flink/formats/avro/AvroStreamingFileSinkITCase.java}
(56%)
