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

Posted to commits@flink.apache.org by go...@apache.org on 2022/07/14 13:17:31 UTC

[flink] branch master updated (74f90d722f7 -> 4bafbe25060)

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

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


    from 74f90d722f7 [FLINK-28250][Connector/Kafka] Fix exactly-once Kafka Sink out of memory
     add 4bafbe25060 [FLINK-27990][table-planner] Parquet format supports reporting statistics

No new revisions were added by this update.

Summary of changes:
 flink-formats/flink-parquet/pom.xml                |   8 +
 .../formats/parquet/ParquetFileFormatFactory.java  | 280 +++++++++++++++++-
 .../vector/reader/TimestampColumnReader.java       |   2 +-
 .../ParquetFileSystemStatisticsReportTest.java     |  53 ++++
 .../parquet/ParquetFormatStatisticsReportTest.java | 198 +++++++++++++
 flink-formats/pom.xml                              |   1 +
 .../utils/CatalogTableStatisticsConverter.java     |   7 +-
 .../planner/catalog/CatalogStatisticsTest.java     |   6 +-
 .../planner/utils/StatisticsReportTestBase.java    | 315 +++++++++++++++++++++
 9 files changed, 860 insertions(+), 10 deletions(-)
 create mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetFileSystemStatisticsReportTest.java
 create mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetFormatStatisticsReportTest.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/utils/StatisticsReportTestBase.java