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 59809fc [FLINK-20209][web] Add tolerable failed checkpoints config to
web ui
add 7b68d53 [FLINK-20509][table-planner-blink] Refactor verifyPlan
methods in TableTestBase
No new revisions were added by this update.
Summary of changes:
.../flink/connector/hbase1/HBaseTablePlanTest.java | 10 +-
.../flink/connector/hbase1/HBaseTablePlanTest.xml | 4 +-
.../flink/connector/hbase2/HBaseTablePlanTest.java | 10 +-
.../flink/connector/hbase2/HBaseTablePlanTest.xml | 4 +-
.../connector/jdbc/table/JdbcTablePlanTest.java | 2 +-
.../connector/jdbc/table/JdbcTablePlanTest.xml | 4 +-
.../table/planner/delegation/PlannerBase.scala | 6 +
.../planner/catalog/JavaCatalogTableTest.java | 8 +-
.../ProjectWatermarkAssignerTransposeRuleTest.java | 22 +-
.../PushFilterIntoTableSourceScanRuleTest.java | 2 +-
.../PushPartitionIntoTableSourceScanRuleTest.java | 2 +-
.../PushProjectIntoTableSourceScanRuleTest.java | 10 +-
.../PushWatermarkIntoTableSourceScanRuleTest.java | 16 +-
.../planner/plan/stream/sql/NullTypeTest.java | 16 +-
.../planner/plan/stream/table/ValuesTest.java | 20 +-
.../table/planner/catalog/JavaCatalogTableTest.xml | 24 +-
.../table/planner/plan/batch/sql/CalcTest.xml | 80 +-
.../planner/plan/batch/sql/DagOptimizationTest.xml | 72 +-
.../planner/plan/batch/sql/DeadlockBreakupTest.xml | 56 +-
.../planner/plan/batch/sql/LegacyLimitTest.xml | 60 +-
.../planner/plan/batch/sql/LegacySinkTest.xml | 8 +-
.../plan/batch/sql/LegacyTableSourceTest.xml | 60 +-
.../table/planner/plan/batch/sql/LimitTest.xml | 60 +-
.../plan/batch/sql/MultipleInputCreationTest.xml | 136 ++--
.../plan/batch/sql/PartitionableSinkTest.xml | 20 +-
.../plan/batch/sql/PartitionableSourceTest.xml | 48 +-
.../table/planner/plan/batch/sql/RankTest.xml | 32 +-
.../planner/plan/batch/sql/RemoveCollationTest.xml | 72 +-
.../planner/plan/batch/sql/RemoveShuffleTest.xml | 132 +--
.../planner/plan/batch/sql/SetOperatorsTest.xml | 48 +-
.../table/planner/plan/batch/sql/SortLimitTest.xml | 40 +-
.../table/planner/plan/batch/sql/SortTest.xml | 20 +-
.../planner/plan/batch/sql/SubplanReuseTest.xml | 120 +--
.../table/planner/plan/batch/sql/TableScanTest.xml | 32 +-
.../table/planner/plan/batch/sql/TableSinkTest.xml | 12 +-
.../planner/plan/batch/sql/TableSourceTest.xml | 16 +-
.../table/planner/plan/batch/sql/UnionTest.xml | 8 +-
.../table/planner/plan/batch/sql/UnnestTest.xml | 40 +-
.../table/planner/plan/batch/sql/ValuesTest.xml | 16 +-
.../batch/sql/agg/AggregateReduceGroupingTest.xml | 164 ++--
.../plan/batch/sql/agg/DistinctAggregateTest.xml | 100 +--
.../plan/batch/sql/agg/GroupingSetsTest.xml | 140 ++--
.../plan/batch/sql/agg/HashAggregateTest.xml | 168 ++--
.../plan/batch/sql/agg/OverAggregateTest.xml | 92 +--
.../plan/batch/sql/agg/SortAggregateTest.xml | 204 ++---
.../plan/batch/sql/agg/WindowAggregateTest.xml | 252 +++---
.../plan/batch/sql/join/BroadcastHashJoinTest.xml | 56 +-
.../sql/join/BroadcastHashSemiAntiJoinTest.xml | 248 +++---
.../plan/batch/sql/join/JoinReorderTest.xml | 56 +-
.../planner/plan/batch/sql/join/LookupJoinTest.xml | 80 +-
.../plan/batch/sql/join/NestedLoopJoinTest.xml | 116 +--
.../batch/sql/join/NestedLoopSemiAntiJoinTest.xml | 328 ++++----
.../plan/batch/sql/join/SemiAntiJoinTest.xml | 328 ++++----
.../plan/batch/sql/join/ShuffledHashJoinTest.xml | 68 +-
.../sql/join/ShuffledHashSemiAntiJoinTest.xml | 256 +++---
.../plan/batch/sql/join/SingleRowJoinTest.xml | 32 +-
.../plan/batch/sql/join/SortMergeJoinTest.xml | 72 +-
.../batch/sql/join/SortMergeSemiAntiJoinTest.xml | 256 +++---
.../planner/plan/batch/table/AggregateTest.xml | 16 +-
.../table/planner/plan/batch/table/CalcTest.xml | 52 +-
.../plan/batch/table/ColumnFunctionsTest.xml | 4 +-
.../planner/plan/batch/table/CorrelateTest.xml | 28 +-
.../planner/plan/batch/table/GroupWindowTest.xml | 24 +-
.../table/planner/plan/batch/table/JoinTest.xml | 52 +-
.../plan/batch/table/PythonAggregateTest.xml | 8 +-
.../planner/plan/batch/table/PythonCalcTest.xml | 4 +-
.../batch/table/PythonGroupWindowAggregateTest.xml | 12 +-
.../batch/table/PythonOverWindowAggregateTest.xml | 8 +-
.../planner/plan/batch/table/SetOperatorsTest.xml | 32 +-
.../stringexpr/CorrelateStringExpressionTest.xml | 32 +-
.../batch/table/stringexpr/SetOperatorsTest.xml | 8 +-
.../planner/plan/common/ViewsExpandingTest.xml | 40 +-
.../table/planner/plan/hint/OptionsHintTest.xml | 48 +-
.../logical/AggregateReduceGroupingRuleTest.xml | 164 ++--
.../logical/CalcPruneAggregateCallRuleTest.xml | 60 +-
.../CalcPythonCorrelateTransposeRuleTest.xml | 4 +-
.../rules/logical/CalcRankTransposeRuleTest.xml | 36 +-
.../rules/logical/ConvertToNotInOrInRuleTest.xml | 88 +-
.../rules/logical/CorrelateSortToRankRuleTest.xml | 32 +-
.../logical/DecomposeGroupingSetsRuleTest.xml | 28 +-
.../rules/logical/ExpressionReductionRulesTest.xml | 18 +-
...nkAggregateExpandDistinctAggregatesRuleTest.xml | 108 +--
.../FlinkAggregateJoinTransposeRuleTest.xml | 32 +-
.../rules/logical/FlinkAggregateRemoveRuleTest.xml | 100 +--
.../plan/rules/logical/FlinkCalcMergeRuleTest.xml | 36 +-
.../plan/rules/logical/FlinkFilterJoinRuleTest.xml | 56 +-
.../logical/FlinkJoinPushExpressionsRuleTest.xml | 16 +-
.../rules/logical/FlinkJoinToMultiJoinRuleTest.xml | 8 +-
.../rules/logical/FlinkLimit0RemoveRuleTest.xml | 36 +-
.../FlinkLogicalRankRuleForConstantRangeTest.xml | 60 +-
.../FlinkLogicalRankRuleForRangeEndTest.xml | 52 +-
.../rules/logical/FlinkPruneEmptyRulesTest.xml | 8 +-
.../FlinkSemiAntiJoinFilterTransposeRuleTest.xml | 8 +-
.../FlinkSemiAntiJoinJoinTransposeRuleTest.xml | 144 ++--
.../FlinkSemiAntiJoinProjectTransposeRuleTest.xml | 8 +-
.../JoinConditionEqualityTransferRuleTest.xml | 56 +-
.../logical/JoinConditionTypeCoerceRuleTest.xml | 36 +-
.../JoinDependentConditionDerivationRuleTest.xml | 32 +-
.../rules/logical/JoinDeriveNullFilterRuleTest.xml | 36 +-
...calCorrelateToJoinFromTemporalTableRuleTest.xml | 24 +-
.../plan/rules/logical/LogicalUnnestRuleTest.xml | 40 +-
.../logical/ProjectPruneAggregateCallRuleTest.xml | 60 +-
.../ProjectSemiAntiJoinTransposeRuleTest.xml | 68 +-
.../ProjectWatermarkAssignerTransposeRuleTest.xml | 44 +-
...PushFilterIntoLegacyTableSourceScanRuleTest.xml | 60 +-
.../PushFilterIntoTableSourceScanRuleTest.xml | 60 +-
.../PushLimitIntoLegacyTableSourceScanRuleTest.xml | 28 +-
.../PushLimitIntoTableSourceScanRuleTest.xml | 28 +-
...hPartitionIntoLegacyTableSourceScanRuleTest.xml | 216 ++---
.../PushPartitionIntoTableSourceScanRuleTest.xml | 228 +++---
...ushProjectIntoLegacyTableSourceScanRuleTest.xml | 32 +-
.../PushProjectIntoTableSourceScanRuleTest.xml | 48 +-
.../PushWatermarkIntoTableSourceScanRuleTest.xml | 32 +-
.../plan/rules/logical/PythonCalcSplitRuleTest.xml | 104 +--
.../rules/logical/PythonCorrelateSplitRuleTest.xml | 16 +-
.../logical/RankNumberColumnRemoveRuleTest.xml | 16 +-
.../ReplaceIntersectWithSemiJoinRuleTest.xml | 16 +-
.../logical/ReplaceMinusWithAntiJoinRuleTest.xml | 16 +-
.../plan/rules/logical/RewriteCoalesceRuleTest.xml | 20 +-
.../rules/logical/RewriteIntersectAllRuleTest.xml | 16 +-
.../plan/rules/logical/RewriteMinusAllRuleTest.xml | 16 +-
.../logical/RewriteMultiJoinConditionRuleTest.xml | 52 +-
.../logical/SimplifyFilterConditionRuleTest.xml | 28 +-
.../logical/SimplifyJoinConditionRuleTest.xml | 8 +-
.../plan/rules/logical/SplitAggregateRuleTest.xml | 64 +-
.../SplitPythonConditionFromCorrelateRuleTest.xml | 4 +-
.../SplitPythonConditionFromJoinRuleTest.xml | 8 +-
.../TemporalJoinRewriteWithUniqueKeyRuleTest.xml | 8 +-
.../rules/logical/WindowGroupReorderRuleTest.xml | 40 +-
.../subquery/FlinkRewriteSubQueryRuleTest.xml | 76 +-
.../logical/subquery/SubQueryAntiJoinTest.xml | 296 +++----
.../logical/subquery/SubQuerySemiJoinTest.xml | 588 +++++++-------
.../SubqueryCorrelateVariablesValidationTest.xml | 8 +-
.../physical/batch/EnforceLocalHashAggRuleTest.xml | 24 +-
.../physical/batch/EnforceLocalSortAggRuleTest.xml | 36 +-
.../batch/RemoveRedundantLocalHashAggRuleTest.xml | 18 +-
.../batch/RemoveRedundantLocalRankRuleTest.xml | 12 +-
.../batch/RemoveRedundantLocalSortAggRuleTest.xml | 20 +-
.../physical/stream/ChangelogModeInferenceTest.xml | 28 +-
.../table/planner/plan/stream/sql/CalcTest.xml | 80 +-
.../plan/stream/sql/DagOptimizationTest.xml | 84 +-
.../planner/plan/stream/sql/DeduplicateTest.xml | 32 +-
.../planner/plan/stream/sql/LegacySinkTest.xml | 36 +-
.../plan/stream/sql/LegacyTableSourceTest.xml | 96 +--
.../table/planner/plan/stream/sql/LimitTest.xml | 136 ++--
.../plan/stream/sql/MiniBatchIntervalInferTest.xml | 52 +-
.../plan/stream/sql/ModifiedMonotonicityTest.xml | 24 +-
.../plan/stream/sql/PartitionableSinkTest.xml | 16 +-
.../plan/stream/sql/PartitionableSourceTest.xml | 48 +-
.../table/planner/plan/stream/sql/RankTest.xml | 104 +--
.../stream/sql/RelTimeIndicatorConverterTest.xml | 60 +-
.../planner/plan/stream/sql/SetOperatorsTest.xml | 48 +-
.../planner/plan/stream/sql/SortLimitTest.xml | 236 +++---
.../table/planner/plan/stream/sql/SortTest.xml | 36 +-
.../plan/stream/sql/SourceWatermarkTest.xml | 24 +-
.../planner/plan/stream/sql/SubplanReuseTest.xml | 80 +-
.../planner/plan/stream/sql/TableScanTest.xml | 112 +--
.../planner/plan/stream/sql/TableSinkTest.xml | 32 +-
.../planner/plan/stream/sql/TableSourceTest.xml | 32 +-
.../table/planner/plan/stream/sql/UnionTest.xml | 8 +-
.../table/planner/plan/stream/sql/UnnestTest.xml | 40 +-
.../table/planner/plan/stream/sql/ValuesTest.xml | 16 +-
.../planner/plan/stream/sql/agg/AggregateTest.xml | 68 +-
.../plan/stream/sql/agg/DistinctAggregateTest.xml | 256 +++---
.../plan/stream/sql/agg/GroupingSetsTest.xml | 136 ++--
.../stream/sql/agg/IncrementalAggregateTest.xml | 64 +-
.../plan/stream/sql/agg/OverAggregateTest.xml | 76 +-
.../plan/stream/sql/agg/TwoStageAggregateTest.xml | 28 +-
.../plan/stream/sql/agg/WindowAggregateTest.xml | 88 +-
.../plan/stream/sql/join/IntervalJoinTest.xml | 72 +-
.../plan/stream/sql/join/JoinReorderTest.xml | 56 +-
.../planner/plan/stream/sql/join/JoinTest.xml | 140 ++--
.../plan/stream/sql/join/LookupJoinTest.xml | 112 +--
.../plan/stream/sql/join/SemiAntiJoinTest.xml | 324 ++++----
.../stream/sql/join/TemporalFunctionJoinTest.xml | 16 +-
.../plan/stream/sql/join/TemporalJoinTest.xml | 76 +-
.../planner/plan/stream/table/AggregateTest.xml | 60 +-
.../table/planner/plan/stream/table/CalcTest.xml | 44 +-
.../plan/stream/table/ColumnFunctionsTest.xml | 56 +-
.../planner/plan/stream/table/CorrelateTest.xml | 48 +-
.../stream/table/GroupWindowTableAggregateTest.xml | 12 +-
.../planner/plan/stream/table/GroupWindowTest.xml | 112 +--
.../table/planner/plan/stream/table/JoinTest.xml | 68 +-
.../plan/stream/table/LegacyTableSourceTest.xml | 48 +-
.../planner/plan/stream/table/OverWindowTest.xml | 68 +-
.../plan/stream/table/PythonAggregateTest.xml | 12 +-
.../planner/plan/stream/table/PythonCalcTest.xml | 4 +-
.../table/PythonGroupWindowAggregateTest.xml | 16 +-
.../stream/table/PythonOverWindowAggregateTest.xml | 16 +-
.../plan/stream/table/PythonTableAggregateTest.xml | 12 +-
.../planner/plan/stream/table/SetOperatorsTest.xml | 20 +-
.../plan/stream/table/TableAggregateTest.xml | 28 +-
.../planner/plan/stream/table/TableSourceTest.xml | 32 +-
.../stream/table/TemporalTableFunctionJoinTest.xml | 20 +-
.../plan/stream/table/TwoStageAggregateTest.xml | 24 +-
.../table/planner/plan/stream/table/ValuesTest.xml | 40 +-
.../apache/flink/table/api/batch/ExplainTest.scala | 2 +-
.../table/planner/plan/batch/sql/CalcTest.scala | 40 +-
.../plan/batch/sql/DagOptimizationTest.scala | 36 +-
.../plan/batch/sql/DeadlockBreakupTest.scala | 28 +-
.../planner/plan/batch/sql/LegacyLimitTest.scala | 34 +-
.../planner/plan/batch/sql/LegacySinkTest.scala | 4 +-
.../plan/batch/sql/LegacyTableSourceTest.scala | 33 +-
.../plan/batch/sql/MultipleInputCreationTest.scala | 34 +-
.../plan/batch/sql/PartitionableSinkTest.scala | 14 +-
.../plan/batch/sql/PartitionableSourceTest.scala | 8 +-
.../table/planner/plan/batch/sql/RankTest.scala | 28 +-
.../plan/batch/sql/RemoveCollationTest.scala | 36 +-
.../planner/plan/batch/sql/RemoveShuffleTest.scala | 66 +-
.../planner/plan/batch/sql/SetOperatorsTest.scala | 33 +-
.../planner/plan/batch/sql/SortLimitTest.scala | 20 +-
.../table/planner/plan/batch/sql/SortTest.scala | 10 +-
.../planner/plan/batch/sql/SubplanReuseTest.scala | 62 +-
.../planner/plan/batch/sql/TableScanTest.scala | 22 +-
.../planner/plan/batch/sql/TableSinkTest.scala | 6 +-
.../planner/plan/batch/sql/TableSourceTest.scala | 8 +-
.../table/planner/plan/batch/sql/UnionTest.scala | 4 +-
.../table/planner/plan/batch/sql/UnnestTest.scala | 2 +-
.../table/planner/plan/batch/sql/ValuesTest.scala | 8 +-
.../sql/agg/AggregateReduceGroupingTest.scala | 2 +-
.../plan/batch/sql/agg/AggregateTestBase.scala | 40 +-
.../plan/batch/sql/agg/DistinctAggregateTest.scala | 2 +-
.../plan/batch/sql/agg/GroupingSetsTest.scala | 73 +-
.../plan/batch/sql/agg/OverAggregateTest.scala | 56 +-
.../plan/batch/sql/agg/WindowAggregateTest.scala | 65 +-
.../planner/plan/batch/sql/join/JoinTestBase.scala | 64 +-
.../plan/batch/sql/join/LookupJoinTest.scala | 26 +-
.../plan/batch/sql/join/SemiAntiJoinTestBase.scala | 166 ++--
.../plan/batch/sql/join/SingleRowJoinTest.scala | 18 +-
.../plan/batch/sql/join/TemporalJoinTest.scala | 8 +-
.../planner/plan/batch/table/AggregateTest.scala | 8 +-
.../table/planner/plan/batch/table/CalcTest.scala | 26 +-
.../plan/batch/table/ColumnFunctionsTest.scala | 4 +-
.../planner/plan/batch/table/CorrelateTest.scala | 16 +-
.../planner/plan/batch/table/GroupWindowTest.scala | 18 +-
.../table/planner/plan/batch/table/JoinTest.scala | 32 +-
.../plan/batch/table/PythonAggregateTest.scala | 6 +-
.../planner/plan/batch/table/PythonCalcTest.scala | 2 +-
.../table/PythonGroupWindowAggregateTest.scala | 10 +-
.../table/PythonOverWindowAggregateTest.scala | 4 +-
.../plan/batch/table/SetOperatorsTest.scala | 16 +-
.../table/TemporalTableFunctionJoinTest.scala | 4 +-
.../stringexpr/CorrelateStringExpressionTest.scala | 17 +-
.../batch/table/stringexpr/SetOperatorsTest.scala | 4 +-
.../table/validation/CorrelateValidationTest.scala | 2 +-
.../table/validation/JoinValidationTest.scala | 2 +-
.../common/AggregateReduceGroupingTestBase.scala | 91 ++-
.../plan/common/DistinctAggregateTestBase.scala | 62 +-
.../planner/plan/common/JoinReorderTestBase.scala | 28 +-
.../table/planner/plan/common/UnnestTestBase.scala | 29 +-
.../planner/plan/common/ViewsExpandingTest.scala | 10 +-
.../table/planner/plan/hint/OptionsHintTest.scala | 14 +-
.../logical/AggregateReduceGroupingRuleTest.scala | 2 +-
.../CalcPythonCorrelateTransposeRuleTest.scala | 2 +-
.../rules/logical/CalcRankTransposeRuleTest.scala | 18 +-
.../rules/logical/ConvertToNotInOrInRuleTest.scala | 50 +-
.../logical/CorrelateSortToRankRuleTest.scala | 16 +-
.../logical/DecomposeGroupingSetsRuleTest.scala | 16 +-
.../logical/ExpressionReductionRulesTest.scala | 8 +-
...AggregateExpandDistinctAggregatesRuleTest.scala | 6 +-
.../FlinkAggregateJoinTransposeRuleTest.scala | 18 +-
.../logical/FlinkAggregateRemoveRuleTest.scala | 52 +-
.../rules/logical/FlinkCalcMergeRuleTest.scala | 18 +-
.../rules/logical/FlinkFilterJoinRuleTest.scala | 29 +-
.../logical/FlinkJoinPushExpressionsRuleTest.scala | 9 +-
.../logical/FlinkJoinToMultiJoinRuleTest.scala | 4 +-
.../rules/logical/FlinkLimit0RemoveRuleTest.scala | 18 +-
.../FlinkLogicalRankRuleForConstantRangeTest.scala | 30 +-
.../FlinkLogicalRankRuleForRangeEndTest.scala | 28 +-
.../rules/logical/FlinkPruneEmptyRulesTest.scala | 4 +-
.../FlinkSemiAntiJoinFilterTransposeRuleTest.scala | 4 +-
.../FlinkSemiAntiJoinJoinTransposeRuleTest.scala | 72 +-
...FlinkSemiAntiJoinProjectTransposeRuleTest.scala | 4 +-
.../JoinConditionEqualityTransferRuleTest.scala | 28 +-
.../logical/JoinConditionTypeCoerceRuleTest.scala | 18 +-
.../JoinDependentConditionDerivationRuleTest.scala | 16 +-
.../logical/JoinDeriveNullFilterRuleTest.scala | 18 +-
...lCorrelateToJoinFromTemporalTableRuleTest.scala | 23 +-
.../plan/rules/logical/LogicalUnnestRuleTest.scala | 2 +-
.../ProjectSemiAntiJoinTransposeRuleTest.scala | 34 +-
.../logical/PruneAggregateCallRuleTestBase.scala | 30 +-
...shFilterIntoLegacyTableSourceScanRuleTest.scala | 30 +-
...ushLimitIntoLegacyTableSourceScanRuleTest.scala | 20 +-
...artitionIntoLegacyTableSourceScanRuleTest.scala | 36 +-
...hProjectIntoLegacyTableSourceScanRuleTest.scala | 16 +-
.../rules/logical/PythonCalcSplitRuleTest.scala | 52 +-
.../logical/PythonCorrelateSplitRuleTest.scala | 8 +-
.../logical/RankNumberColumnRemoveRuleTest.scala | 8 +-
.../ReplaceIntersectWithSemiJoinRuleTest.scala | 9 +-
.../logical/ReplaceMinusWithAntiJoinRuleTest.scala | 8 +-
.../rules/logical/RewriteCoalesceRuleTest.scala | 14 +-
.../logical/RewriteIntersectAllRuleTest.scala | 8 +-
.../rules/logical/RewriteMinusAllRuleTest.scala | 8 +-
.../RewriteMultiJoinConditionRuleTest.scala | 26 +-
.../logical/SimplifyFilterConditionRuleTest.scala | 15 +-
.../logical/SimplifyJoinConditionRuleTest.scala | 4 +-
.../rules/logical/SplitAggregateRuleTest.scala | 32 +-
...SplitPythonConditionFromCorrelateRuleTest.scala | 2 +-
.../SplitPythonConditionFromJoinRuleTest.scala | 4 +-
.../TemporalJoinRewriteWithUniqueKeyRuleTest.scala | 12 +-
.../rules/logical/WindowGroupReorderRuleTest.scala | 20 +-
.../subquery/FlinkRewriteSubQueryRuleTest.scala | 56 +-
.../logical/subquery/SubQueryAntiJoinTest.scala | 213 ++---
.../logical/subquery/SubQuerySemiJoinTest.scala | 443 +++++-----
.../SubqueryCorrelateVariablesValidationTest.scala | 14 +-
.../batch/EnforceLocalAggRuleTestBase.scala | 12 +-
.../batch/EnforceLocalSortAggRuleTest.scala | 6 +-
.../RemoveRedundantLocalHashAggRuleTest.scala | 6 +-
.../batch/RemoveRedundantLocalRankRuleTest.scala | 6 +-
.../RemoveRedundantLocalSortAggRuleTest.scala | 6 +-
.../stream/ChangelogModeInferenceTest.scala | 15 +-
.../table/planner/plan/stream/sql/CalcTest.scala | 40 +-
.../plan/stream/sql/DagOptimizationTest.scala | 42 +-
.../planner/plan/stream/sql/DeduplicateTest.scala | 16 +-
.../planner/plan/stream/sql/LegacySinkTest.scala | 22 +-
.../plan/stream/sql/LegacyTableSourceTest.scala | 55 +-
.../table/planner/plan/stream/sql/LimitTest.scala | 72 +-
.../stream/sql/MiniBatchIntervalInferTest.scala | 26 +-
.../plan/stream/sql/ModifiedMonotonicityTest.scala | 12 +-
.../plan/stream/sql/PartitionableSinkTest.scala | 12 +-
.../plan/stream/sql/PartitionableSourceTest.scala | 8 +-
.../table/planner/plan/stream/sql/RankTest.scala | 70 +-
.../stream/sql/RelTimeIndicatorConverterTest.scala | 30 +-
.../planner/plan/stream/sql/SetOperatorsTest.scala | 33 +-
.../planner/plan/stream/sql/SortLimitTest.scala | 118 +--
.../table/planner/plan/stream/sql/SortTest.scala | 18 +-
.../plan/stream/sql/SourceWatermarkTest.scala | 12 +-
.../planner/plan/stream/sql/SubplanReuseTest.scala | 42 +-
.../planner/plan/stream/sql/TableScanTest.scala | 60 +-
.../planner/plan/stream/sql/TableSinkTest.scala | 26 +-
.../planner/plan/stream/sql/TableSourceTest.scala | 18 +-
.../table/planner/plan/stream/sql/UnionTest.scala | 4 +-
.../table/planner/plan/stream/sql/UnnestTest.scala | 2 +-
.../table/planner/plan/stream/sql/ValuesTest.scala | 8 +-
.../plan/stream/sql/agg/AggregateTest.scala | 40 +-
.../stream/sql/agg/DistinctAggregateTest.scala | 33 +-
.../plan/stream/sql/agg/GroupingSetsTest.scala | 73 +-
.../plan/stream/sql/agg/OverAggregateTest.scala | 46 +-
.../stream/sql/agg/TwoStageAggregateTest.scala | 14 +-
.../plan/stream/sql/agg/WindowAggregateTest.scala | 60 +-
.../plan/stream/sql/join/IntervalJoinTest.scala | 46 +-
.../planner/plan/stream/sql/join/JoinTest.scala | 70 +-
.../plan/stream/sql/join/LookupJoinTest.scala | 32 +-
.../plan/stream/sql/join/SemiAntiJoinTest.scala | 164 ++--
.../stream/sql/join/TemporalFunctionJoinTest.scala | 8 +-
.../plan/stream/sql/join/TemporalJoinTest.scala | 38 +-
.../planner/plan/stream/table/AggregateTest.scala | 30 +-
.../table/planner/plan/stream/table/CalcTest.scala | 22 +-
.../plan/stream/table/ColumnFunctionsTest.scala | 30 +-
.../planner/plan/stream/table/CorrelateTest.scala | 24 +-
.../table/GroupWindowTableAggregateTest.scala | 6 +-
.../plan/stream/table/GroupWindowTest.scala | 56 +-
.../table/planner/plan/stream/table/JoinTest.scala | 34 +-
.../plan/stream/table/LegacyTableSourceTest.scala | 24 +-
.../planner/plan/stream/table/OverWindowTest.scala | 34 +-
.../plan/stream/table/PythonAggregateTest.scala | 6 +-
.../planner/plan/stream/table/PythonCalcTest.scala | 2 +-
.../table/PythonGroupWindowAggregateTest.scala | 10 +-
.../table/PythonOverWindowAggregateTest.scala | 8 +-
.../stream/table/PythonTableAggregateTest.scala | 6 +-
.../plan/stream/table/SetOperatorsTest.scala | 10 +-
.../plan/stream/table/TableAggregateTest.scala | 14 +-
.../plan/stream/table/TableSourceTest.scala | 18 +-
.../table/TemporalTableFunctionJoinTest.scala | 12 +-
.../plan/stream/table/TwoStageAggregateTest.scala | 12 +-
.../table/validation/AggregateValidationTest.scala | 2 +-
.../table/validation/CorrelateValidationTest.scala | 3 +-
.../GroupWindowTableAggregateValidationTest.scala | 2 +-
.../flink/table/planner/utils/TableTestBase.scala | 903 +++++++++++++++------
369 files changed, 9237 insertions(+), 8734 deletions(-)
