This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5390e91 [FLINK-22710][formats] Explicitly set the bucket assigner to
avoid writing into two buckets in the tests
add 50411b6 [FLINK-23911][table-common] Emphasize that
#applyReadableMetadata must be idempotent
add 27fcc4a [FLINK-23911][table-planner] Make SupportsReadingMetadata
visible in the plan digests
add 97650c0 [FLINK-23911][table-planner] Apply metadata spec even if no
metadata were used
No new revisions were added by this update.
Summary of changes:
.../source/abilities/SupportsReadingMetadata.java | 3 +
.../plan/abilities/source/ReadingMetadataSpec.java | 4 +
.../PushProjectIntoTableSourceScanRule.java | 30 +++--
.../table/planner/catalog/JavaCatalogTableTest.xml | 6 +-
.../table/planner/plan/batch/sql/LimitTest.xml | 10 +-
.../plan/batch/sql/PartitionableSourceTest.xml | 6 +-
.../planner/plan/batch/sql/SubplanReuseTest.xml | 12 +-
.../table/planner/plan/batch/sql/TableScanTest.xml | 24 ++--
.../planner/plan/batch/sql/TableSourceTest.xml | 38 ++++---
.../testSimpleProject.out | 14 ++-
.../testChangelogSource.out | 14 ++-
.../testUpsertSource.out | 14 ++-
...gCallsWithGroupBy[isMiniBatchEnabled=false].out | 16 ++-
...ggCallsWithGroupBy[isMiniBatchEnabled=true].out | 16 ++-
...AggWithoutGroupBy[isMiniBatchEnabled=false].out | 16 ++-
...eAggWithoutGroupBy[isMiniBatchEnabled=true].out | 16 ++-
.../testProcTimeTumbleWindow.out | 14 ++-
.../testIncrementalAggregate.out | 14 ++-
...lAggregateWithSumCountDistinctAndRetraction.out | 14 ++-
.../testProcessingTimeInnerJoinWithOnClause.out | 14 ++-
.../testRowTimeInnerJoinWithOnClause.out | 14 ++-
.../JoinJsonPlanTest_jsonplan/testInnerJoin.out | 24 +++-
.../testInnerJoinWithEqualPk.out | 28 ++++-
.../testInnerJoinWithPk.out | 28 ++++-
.../testLeftJoinNonEqui.out | 28 ++++-
.../LimitJsonPlanTest_jsonplan/testLimit.out | 12 +-
.../testProcTimeBoundedNonPartitionedRangeOver.out | 21 +++-
.../testProcTimeBoundedPartitionedRangeOver.out | 21 +++-
...undedPartitionedRowsOverWithBuiltinProctime.out | 21 +++-
.../testProcTimeUnboundedPartitionedRangeOver.out | 21 +++-
...stProctimeBoundedDistinctPartitionedRowOver.out | 21 +++-
.../testRowTimeBoundedPartitionedRowsOver.out | 21 +++-
.../testPythonCalc.out | 14 ++-
.../testPythonFunctionInWhereClause.out | 14 ++-
.../tesPythonAggCallsWithGroupBy.out | 16 ++-
.../testProcTimeBoundedNonPartitionedRangeOver.out | 21 +++-
.../testProcTimeBoundedPartitionedRangeOver.out | 21 +++-
...undedPartitionedRowsOverWithBuiltinProctime.out | 21 +++-
.../testProcTimeUnboundedPartitionedRangeOver.out | 21 +++-
.../testRowTimeBoundedPartitionedRowsOver.out | 21 +++-
.../testSortLimit.out | 14 ++-
.../testPartitioning.out | 14 ++-
.../testPartitionPushDown.out | 14 ++-
.../testProjectPushDown.out | 14 ++-
.../testReadingMetadata.out | 2 +-
.../testSortProcessingTime.out | 14 ++-
.../testSortRowTime.out | 14 ++-
.../UnionJsonPlanTest_jsonplan/testUnion.out | 14 ++-
.../testProcTimeCumulateWindow.out | 14 ++-
.../testProcTimeTumbleWindow.out | 14 ++-
.../testEventTimeTumbleWindow.out | 28 ++++-
.../PushProjectIntoTableSourceScanRuleTest.xml | 28 ++---
.../ExpandWindowTableFunctionTransposeRuleTest.xml | 6 +-
...AssignerChangelogNormalizeTransposeRuleTest.xml | 10 +-
.../plan/stream/sql/LimitableSourceTest.xml | 42 +++----
.../plan/stream/sql/MiniBatchIntervalInferTest.xml | 24 ++--
.../plan/stream/sql/PartitionableSourceTest.xml | 6 +-
.../plan/stream/sql/SourceWatermarkTest.xml | 8 +-
.../planner/plan/stream/sql/SubplanReuseTest.xml | 12 +-
.../planner/plan/stream/sql/TableScanTest.xml | 14 +--
.../planner/plan/stream/sql/TableSinkTest.xml | 2 +-
.../planner/plan/stream/sql/TableSourceTest.xml | 12 +-
.../table/planner/plan/stream/sql/UnionTest.xml | 4 +-
.../plan/stream/sql/agg/GroupWindowTest.xml | 2 +-
.../plan/stream/sql/agg/WindowAggregateTest.xml | 122 ++++++++++-----------
.../plan/stream/sql/join/IntervalJoinTest.xml | 4 +-
.../planner/plan/stream/sql/join/JoinTest.xml | 2 +-
.../plan/stream/sql/join/WindowJoinTest.xml | 100 ++++++++---------
.../planner/plan/stream/table/TableSourceTest.xml | 4 +-
69 files changed, 963 insertions(+), 299 deletions(-)
