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/08/22 02:23:17 UTC

[flink] branch master updated (97519d1683f -> 10e4c829021)

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 97519d1683f [FLINK-29028][python][docs] Align DataStream.cache in Python DataStream API
     add 10e4c829021 [FLINK-28992][table-planner] Fix: Change Ndv takes the max value instead of sum of all partitions when getting partition table column stats

No new revisions were added by this update.

Summary of changes:
 .../table/catalog/hive/util/HiveStatsUtil.java     |  32 ++++--
 .../apache/flink/table/plan/stats/ColumnStats.java |   9 +-
 .../apache/flink/table/plan/stats/TableStats.java  |  19 +--
 .../flink/table/plan/stats/TableStatsTest.java     |  93 ++++++++++++---
 .../utils/CatalogTableStatisticsConverter.java     |   9 +-
 .../program/FlinkRecomputeStatisticsProgram.java   |  14 ++-
 ...ushPartitionIntoLegacyTableSourceScanRule.scala |   6 +-
 .../file/table/FileSystemStatisticsReportTest.java | 128 ++++++++++++++++++++-
 .../planner/catalog/CatalogStatisticsTest.java     |  22 ++--
 9 files changed, 273 insertions(+), 59 deletions(-)