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

Posted to commits@flink.apache.org by di...@apache.org on 2022/07/04 07:12:21 UTC

[flink] branch master updated (94915d6c9e1 -> 75024ceba42)

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

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


    from 94915d6c9e1 [FLINK-28310][rest] Introduce aggregating task metrics
     add 75024ceba42 [FLINK-28336][python][format] Support parquet-avro format DataStream API

No new revisions were added by this update.

Summary of changes:
 .../docs/connectors/datastream/formats/parquet.md  |  31 ++-
 .../docs/connectors/datastream/formats/parquet.md  |  31 ++-
 flink-formats/flink-sql-parquet/pom.xml            |  23 ++
 .../src/main/resources/META-INF/NOTICE             |   1 +
 .../connectors/tests/test_file_system.py           | 307 +++++++++++++++++++++
 .../pyflink/datastream/formats}/__init__.py        |   0
 .../formats/avro.py}                               |  44 +--
 flink-python/pyflink/datastream/formats/parquet.py |  47 ++++
 flink-python/pyflink/datastream/tests/test_util.py |   7 +-
 flink-python/pyflink/pyflink_gateway_server.py     |   1 +
 10 files changed, 469 insertions(+), 23 deletions(-)
 create mode 100644 flink-python/pyflink/datastream/connectors/tests/test_file_system.py
 copy {flink-end-to-end-tests/flink-python-test/python/datastream => flink-python/pyflink/datastream/formats}/__init__.py (100%)
 copy flink-python/pyflink/{table/changelog_mode.py => datastream/formats/avro.py} (52%)
 create mode 100644 flink-python/pyflink/datastream/formats/parquet.py