[flink] branch master updated (a3aec76 -> 73608c9)

[tw...@apache.org]

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(-)