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/08 07:04:43 UTC

[flink] branch master updated (a069a306a0c -> e164e22fc83)

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 a069a306a0c [FLINK-28247][hive] fix "no any field presented in group by" exception when over window contains grouping function in Hive dialect
     add e164e22fc83 [FLINK-28413][python][parquet] Support ParquetColumnarRowInputFormat in PyFlink

No new revisions were added by this update.

Summary of changes:
 .../docs/connectors/datastream/formats/parquet.md  | 78 +++++++++++++++++--
 .../docs/connectors/datastream/formats/parquet.md  | 79 ++++++++++++++++---
 .../parquet/ParquetColumnarRowInputFormat.java     |  2 +-
 .../pyflink/datastream/connectors/__init__.py      |  3 +-
 .../pyflink/datastream/connectors/file_system.py   | 27 +++++++
 .../connectors/tests/test_file_system.py           | 88 ++++++++++++++++------
 .../pyflink/datastream/formats/__init__.py         |  6 +-
 flink-python/pyflink/datastream/formats/parquet.py | 52 ++++++++++++-
 .../datastream/stream_execution_environment.py     |  3 +-
 .../flink/streaming/api/utils/PythonTypeUtils.java | 54 +++++++++++++
 10 files changed, 340 insertions(+), 52 deletions(-)