You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by al...@apache.org on 2020/10/12 10:52:01 UTC

[flink] branch master updated (5076e4a -> b358926)

This is an automated email from the ASF dual-hosted git repository.

aljoscha pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 5076e4a  [FLINK-18722][mesos] Switch to the new active resource manager for Mesos deployment.
     add e056544  [hotfix] Rename ParquetStreamingFileSinkITCase
     add fdea3cd  [hotfix] Fix the generic parameter declaration of ParquetAvroStreamingFileSinkITCase
     add b358926  [FLINK-11427][formats] Add protobuf parquet support for StreamingFileSink

No new revisions were added by this update.

Summary of changes:
 docs/dev/connectors/streamfile_sink.md             |  37 ++++++
 docs/dev/connectors/streamfile_sink.zh.md          |  37 ++++++
 flink-formats/flink-parquet/pom.xml                |  81 ++++++++++++++
 .../parquet/protobuf/ParquetProtoWriters.java      |  74 ++++++++++++
 ...ava => ParquetAvroStreamingFileSinkITCase.java} |   5 +-
 .../ParquetProtoStreamingFileSinkITCase.java       | 124 +++++++++++++++++++++
 .../test/resources/protobuf/simple_record.proto    |   8 ++
 pom.xml                                            |   1 +
 8 files changed, 364 insertions(+), 3 deletions(-)
 create mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/protobuf/ParquetProtoWriters.java
 rename flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/avro/{ParquetStreamingFileSinkITCase.java => ParquetAvroStreamingFileSinkITCase.java} (97%)
 create mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/protobuf/ParquetProtoStreamingFileSinkITCase.java
 create mode 100644 flink-formats/flink-parquet/src/test/resources/protobuf/simple_record.proto