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 a3aec76 [hotfix][runtime] Adds missing configuration parameter to
cleanup error log message
add d74859e [hotfix][table-planner] Remove unused imports
add 33ce844 [FLINK-26843][table-planner] Use TableConfigUtils to get
local timezone.
add 075b790 [FLINK-26843][table-planner] Use
ShortcutUtils.unwrap[TableConfig/Context]
add 38217d6 [FLINK-26843][table-planner] Replace `TableConfig` with
`ReadableConfig`
add 3ddd74e [FLINK-26843][table-planner] Cleanup TableConfig &
ReadableConfig
add db070b4 [hotfix][table-planner][tests] Cleanup by using PlannerMocks
add 73608c9 [hotfix][table-planner][tests] Cleanup by using
JsonSerdeTestUtil
No new revisions were added by this update.
Summary of changes:
.../internal/StreamTableEnvironmentImplTest.scala | 6 +-
.../table/planner/calcite/FlinkRelBuilder.java | 3 +-
.../plan/abilities/source/FilterPushDownSpec.java | 4 +-
.../logical/PushFilterIntoSourceScanRuleBase.java | 4 +-
.../PushPartitionIntoTableSourceScanRule.java | 4 +-
.../flink/table/planner/utils/ShortcutUtils.java | 13 ++-
.../table/planner/utils/TableConfigUtils.java | 2 +-
.../table/planner/codegen/ExpressionReducer.scala | 2 +-
.../table/planner/delegation/PlannerBase.scala | 4 +-
.../plan/metadata/FlinkRelMdColumnNullCount.scala | 5 +-
.../plan/metadata/FlinkRelMdDistinctRowCount.scala | 5 +-
.../plan/metadata/FlinkRelMdDistribution.scala | 4 +-
.../planner/plan/metadata/FlinkRelMdRowCount.scala | 6 +-
.../plan/metadata/SelectivityEstimator.scala | 5 +-
.../plan/nodes/logical/FlinkLogicalSort.scala | 8 +-
.../batch/BatchPhysicalGroupAggregateBase.scala | 4 +-
.../batch/BatchPhysicalHashAggregate.scala | 7 +-
.../physical/batch/BatchPhysicalJoinBase.scala | 4 +-
.../batch/BatchPhysicalOverAggregateBase.scala | 5 +-
.../batch/BatchPhysicalPythonGroupAggregate.scala | 3 +-
.../nodes/physical/batch/BatchPhysicalRank.scala | 5 +-
.../batch/BatchPhysicalSortAggregate.scala | 5 +-
.../StreamPhysicalGlobalWindowAggregate.scala | 5 +-
.../StreamPhysicalLocalWindowAggregate.scala | 5 +-
.../stream/StreamPhysicalWindowAggregate.scala | 3 +-
.../BatchCommonSubGraphBasedOptimizer.scala | 13 +--
.../table/planner/plan/optimize/RelNodeBlock.scala | 14 ++--
.../StreamCommonSubGraphBasedOptimizer.scala | 13 +--
.../plan/optimize/program/FlinkBatchProgram.scala | 4 +-
.../FlinkChangelogModeInferenceProgram.scala | 8 +-
.../plan/optimize/program/FlinkStreamProgram.scala | 4 +-
.../table/planner/plan/reuse/SubplanReuser.scala | 5 +-
.../plan/rules/logical/FlinkLogicalRankRule.scala | 24 ++----
.../rules/logical/JoinDeriveNullFilterRule.scala | 6 +-
.../PushFilterIntoLegacyTableSourceScanRule.scala | 15 ++--
...ushPartitionIntoLegacyTableSourceScanRule.scala | 7 +-
.../plan/rules/logical/SplitAggregateRule.scala | 10 +--
.../physical/batch/BatchPhysicalAggRuleBase.scala | 11 +--
.../physical/batch/BatchPhysicalHashAggRule.scala | 7 +-
.../physical/batch/BatchPhysicalHashJoinRule.scala | 10 +--
.../physical/batch/BatchPhysicalJoinRuleBase.scala | 5 +-
.../batch/BatchPhysicalNestedLoopJoinRule.scala | 4 +-
.../physical/batch/BatchPhysicalSortAggRule.scala | 7 +-
.../batch/BatchPhysicalSortMergeJoinRule.scala | 6 +-
.../physical/batch/BatchPhysicalSortRule.scala | 5 +-
.../batch/BatchPhysicalWindowAggregateRule.scala | 18 ++---
.../physical/batch/EnforceLocalAggRuleBase.scala | 7 +-
.../physical/stream/IncrementalAggregateRule.scala | 5 +-
.../stream/MiniBatchIntervalInferRule.scala | 7 +-
.../StreamPhysicalGroupWindowAggregateRule.scala | 4 +-
...reamPhysicalGroupWindowTableAggregateRule.scala | 4 +-
.../stream/StreamPhysicalJoinRuleBase.scala | 10 ++-
.../stream/StreamPhysicalTableSourceScanRule.scala | 4 +-
.../stream/TwoStageOptimizedAggregateRule.scala | 5 +-
.../plan/schema/LegacyCatalogSourceTable.scala | 16 ++--
.../table/planner/plan/utils/FlinkRelOptUtil.scala | 10 +--
.../planner/plan/utils/IntervalJoinUtil.scala | 12 +--
.../table/planner/plan/utils/PartitionPruner.scala | 6 +-
.../table/planner/delegation/ParserImplTest.java | 41 ++--------
.../planner/expressions/TypeConversionsTest.java | 16 ++--
.../converter/ExpressionConverterTest.java | 27 +------
.../operations/SqlToOperationConverterTest.java | 41 +++++-----
.../plan/nodes/exec/serde/JsonSerdeTestUtil.java | 22 ++---
.../nodes/exec/serde/LogicalWindowSerdeTest.java | 21 +----
.../plan/nodes/exec/serde/LookupKeySerdeTest.java | 32 +-------
.../nodes/exec/serde/RexWindowBoundSerdeTest.java | 19 +----
.../serde/TemporalTableSourceSpecSerdeTest.java | 10 +--
.../runtime/stream/sql/DataStreamJavaITCase.java | 3 +-
.../flink/table/planner/utils/PlannerMocks.java | 94 +++++++++++++++++++---
.../codegen/WatermarkGeneratorCodeGenTest.scala | 39 ++-------
.../expressions/NonDeterministicTests.scala | 12 +--
.../planner/expressions/TemporalTypesTest.scala | 32 ++++----
.../expressions/utils/ExpressionTestBase.scala | 6 +-
.../metadata/AggCallSelectivityEstimatorTest.scala | 41 ++--------
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 42 ++++------
.../plan/metadata/SelectivityEstimatorTest.scala | 44 +++-------
.../plan/nodes/calcite/RelNodeTestBase.scala | 32 +-------
.../batch/EnforceLocalHashAggRuleTest.scala | 7 +-
.../batch/EnforceLocalSortAggRuleTest.scala | 7 +-
.../plan/stream/sql/agg/GroupWindowTest.scala | 20 ++---
.../planner/plan/utils/PartitionPrunerTest.scala | 10 +--
.../flink/table/planner/utils/TableTestBase.scala | 16 ++--
82 files changed, 452 insertions(+), 589 deletions(-)
