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

Posted to commits@flink.apache.org by li...@apache.org on 2023/01/30 08:08:05 UTC

[flink] branch master updated (7df2a12472f -> 6d17ba88556)

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

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


    from 7df2a12472f [FLINK-30679][hive] Fix IndexOutOfBoundsException for Hive lookup join when column pushdown to Hive lookup table source #21731
     add 6d17ba88556 [FLINK-29558][table-planner] Fix projection pushdown rule select nothing from source when no column is needed logically (#21704)

No new revisions were added by this update.

Summary of changes:
 .../PushProjectIntoTableSourceScanRule.java        | 17 ++++-
 .../PushProjectIntoTableSourceScanRuleTest.java    |  2 +-
 .../planner/plan/batch/sql/TableSourceTest.xml     |  2 +-
 .../plan/batch/sql/agg/HashAggregateTest.xml       | 62 +++++++++++++++++
 .../plan/batch/sql/agg/SortAggregateTest.xml       | 62 +++++++++++++++++
 .../PushProjectIntoTableSourceScanRuleTest.xml     |  4 +-
 .../planner/plan/stream/sql/TableScanTest.xml      |  2 +-
 .../planner/plan/stream/sql/TableSourceTest.xml    |  2 +-
 .../planner/plan/stream/sql/agg/AggregateTest.xml  | 80 ++++++++++++++++++++++
 .../plan/batch/sql/agg/AggregateTestBase.scala     | 15 ++++
 .../plan/stream/sql/agg/AggregateTest.scala        | 59 ++++++++++++++++
 .../batch/sql/agg/AggregateITCaseBase.scala        | 23 ++++++-
 .../runtime/stream/sql/AggregateITCase.scala       | 24 +++++++
 13 files changed, 345 insertions(+), 9 deletions(-)