This is an automated email from the ASF dual-hosted git repository.
leonard pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 7542b56f2ab [FLINK-33469] Implement restore tests for Limit node
(#23675)
new 722e638924b [FLINK-33023][table-planner][JUnit5 Migration] Module:
flink-table-planner/planner/utils (TableTestBase)
new bf6afc3d52e [FLINK-33023][table-planner][JUnit5 Migration] Module:
flink-table-planner/api (TableTestBase)
new 4cd8285274a [FLINK-33023][table-planner][JUnit5 Migration] Module:
flink-connectors/flink-connector-hive (TableTestBase)
new 6564bccbcb2 [FLINK-33023][table-planner][JUnit5 Migration] Module:
flink-table-planner/connector (TableTestBase)
new f44b6764cbd [FLINK-33023][table-planner][JUnit5 Migration] Module:
flink-table-planner/planner/alias (TableTestBase)
new b9923dee789 [FLINK-33023][table-planner][JUnit5 Migration] Module:
flink-table-planner/planner/analyze (TableTestBase)
new 1fbe223a5d7 [FLINK-33023][table-planner][JUnit5 Migration] Module:
flink-table-planner/planner/catalog,expressions,runtime (TableTestBase)
new cdb759b0ecd [FLINK-33023][table-planner][JUnit5 Migration] Module:
flink-table-planner/planner/plan (TableTestBase)
The 8 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../connectors/hive/HiveTemporalJoinITCase.java | 49 +-
.../file/table/FileSystemTableSourceTest.java | 14 +-
.../validation/MatchRecognizeValidationTest.java | 188 +--
...rJoinHintWithCapitalizeJoinHintShuttleTest.java | 14 +-
...rJoinHintWithInvalidPropagationShuttleTest.java | 12 +-
...nHintWithInvalidPropagationShuttleTestBase.java | 8 +-
...pJoinHintWithInvalidPropagationShuttleTest.java | 18 +-
.../analyze/GroupAggregationAnalyzerTest.java | 56 +-
.../NonDeterministicUpdateAnalyzerTest.java | 24 +-
.../planner/catalog/JavaCatalogTableTest.java | 34 +-
.../planner/plan/batch/sql/CalcMergeTest.java | 2 +-
.../plan/batch/sql/DynamicFilteringTest.java | 47 +-
.../plan/batch/sql/DynamicFunctionPlanTest.java | 2 +-
.../plan/batch/sql/ForwardHashExchangeTest.java | 52 +-
.../planner/plan/batch/sql/MatchRecognizeTest.java | 18 +-
.../planner/plan/batch/sql/RowLevelDeleteTest.java | 43 +-
.../planner/plan/batch/sql/RowLevelUpdateTest.java | 66 +-
.../planner/plan/batch/sql/TimeTravelTest.java | 30 +-
.../planner/plan/common/CalcMergeTestBase.java | 26 +-
.../plan/common/DynamicFunctionPlanTestBase.java | 16 +-
.../plan/hints/batch/BroadcastJoinHintTest.java | 2 +-
.../planner/plan/hints/batch/JoinHintTestBase.java | 208 +--
.../plan/hints/batch/NestLoopJoinHintTest.java | 2 +-
.../plan/hints/batch/ShuffleHashJoinHintTest.java | 2 +-
.../plan/hints/batch/ShuffleMergeJoinHintTest.java | 2 +-
.../nodes/exec/UnsupportedNodesInPlanTest.java | 6 +-
.../nodes/exec/operator/BatchOperatorNameTest.java | 52 +-
.../nodes/exec/operator/OperatorNameTestBase.java | 44 +-
.../exec/operator/StreamOperatorNameTest.java | 86 +-
.../MultipleInputNodeCreationProcessorTest.java | 15 +-
.../plan/nodes/exec/stream/CalcJsonPlanTest.java | 20 +-
.../exec/stream/ChangelogSourceJsonPlanTest.java | 14 +-
.../nodes/exec/stream/CorrelateJsonPlanTest.java | 24 +-
.../exec/stream/DeduplicationJsonPlanTest.java | 12 +-
.../plan/nodes/exec/stream/ExpandJsonPlanTest.java | 12 +-
.../exec/stream/GroupAggregateJsonPlanTest.java | 40 +-
.../stream/GroupWindowAggregateJsonPlanTest.java | 22 +-
.../stream/IncrementalAggregateJsonPlanTest.java | 14 +-
.../exec/stream/IntervalJoinJsonPlanTest.java | 14 +-
.../plan/nodes/exec/stream/JoinJsonPlanTest.java | 18 +-
.../nodes/exec/stream/LookupJoinJsonPlanTest.java | 34 +-
.../exec/stream/MatchRecognizeJsonPlanTest.java | 20 +-
.../exec/stream/OverAggregateJsonPlanTest.java | 24 +-
.../nodes/exec/stream/PythonCalcJsonPlanTest.java | 14 +-
.../exec/stream/PythonCorrelateJsonPlanTest.java | 14 +-
.../stream/PythonGroupAggregateJsonPlanTest.java | 12 +-
.../PythonGroupWindowAggregateJsonPlanTest.java | 22 +-
.../stream/PythonOverAggregateJsonPlanTest.java | 20 +-
.../plan/nodes/exec/stream/RankJsonPlanTest.java | 12 +-
.../plan/nodes/exec/stream/SortJsonPlanTest.java | 12 +-
.../nodes/exec/stream/SortLimitJsonPlanTest.java | 12 +-
.../nodes/exec/stream/TableSinkJsonPlanTest.java | 20 +-
.../nodes/exec/stream/TableSourceJsonPlanTest.java | 24 +-
.../exec/stream/TemporalJoinJsonPlanTest.java | 14 +-
.../exec/stream/TemporalSortJsonPlanTest.java | 14 +-
.../plan/nodes/exec/stream/UnionJsonPlanTest.java | 12 +-
.../plan/nodes/exec/stream/ValuesJsonPlanTest.java | 12 +-
.../exec/stream/WatermarkAssignerJsonPlanTest.java | 12 +-
.../exec/stream/WindowAggregateJsonPlanTest.java | 30 +-
.../nodes/exec/stream/WindowJoinJsonPlanTest.java | 12 +-
.../stream/WindowTableFunctionJsonPlanTest.java | 20 +-
.../optimize/ClearQueryBlockAliasResolverTest.java | 2 +-
.../table/planner/plan/optimize/ScanReuseTest.java | 125 +-
.../DynamicPartitionPruningProgramTest.java | 91 +-
.../program/FlinkRuntimeFilterProgramTest.java | 60 +-
.../rules/logical/FlinkFilterJoinRuleTest.java | 116 +-
.../logical/ProjectSnapshotTransposeRuleTest.java | 40 +-
.../ProjectWatermarkAssignerTransposeRuleTest.java | 32 +-
.../PushFilterInCalcIntoTableSourceRuleTest.java | 17 +-
.../PushFilterIntoTableSourceScanRuleTest.java | 25 +-
.../PushFilterIntoTableSourceScanRuleTestBase.java | 44 +-
.../PushLimitIntoTableSourceScanRuleTest.java | 6 +-
.../PushPartitionIntoTableSourceScanRuleTest.java | 13 +-
.../PushProjectIntoTableSourceScanRuleTest.java | 44 +-
.../PushWatermarkIntoTableSourceScanRuleTest.java | 40 +-
...RemoveUnreachableCoalesceArgumentsRuleTest.java | 24 +-
.../WrapJsonAggFunctionArgumentsRuleTest.java | 63 +-
.../PushLocalAggIntoTableSourceScanRuleTest.java | 44 +-
.../PushCalcPastChangelogNormalizeRuleTest.java | 22 +-
.../planner/plan/stream/sql/CalcMergeTest.java | 2 +-
.../plan/stream/sql/DynamicFunctionPlanTest.java | 2 +-
.../plan/stream/sql/InsertIntoValuesTest.java | 6 +-
.../plan/stream/sql/LegacyTableFactoryTest.java | 10 +-
.../planner/plan/stream/sql/NullTypeTest.java | 79 +-
.../planner/plan/stream/table/ValuesTest.java | 90 +-
.../runtime/batch/ParallelismSettingTest.java | 20 +-
.../planner/utils/InternalConfigOptionsTest.java | 28 +-
.../planner/plan/common/ViewsExpandingTest.xml | 20 +-
.../table/planner/plan/hint/OptionsHintTest.xml | 20 +-
.../apache/flink/table/api/batch/ExplainTest.scala | 32 +-
.../flink/table/api/stream/ExplainTest.scala | 32 +-
.../sql/validation/OverWindowValidationTest.scala | 13 +-
.../table/planner/plan/batch/sql/CalcTest.scala | 10 +-
.../plan/batch/sql/CompactManagedTableTest.scala | 6 +-
.../plan/batch/sql/DagOptimizationTest.scala | 2 +-
.../plan/batch/sql/DeadlockBreakupTest.scala | 4 +-
.../planner/plan/batch/sql/LegacyLimitTest.scala | 15 +-
.../planner/plan/batch/sql/LegacySinkTest.scala | 3 +-
.../plan/batch/sql/LegacyTableSourceTest.scala | 13 +-
.../table/planner/plan/batch/sql/LimitTest.scala | 3 +
.../plan/batch/sql/MultipleInputCreationTest.scala | 45 +-
.../plan/batch/sql/OperatorFusionCodegenTest.scala | 18 +-
.../plan/batch/sql/PartitionableSinkTest.scala | 17 +-
.../plan/batch/sql/PartitionableSourceTest.scala | 26 +-
.../table/planner/plan/batch/sql/RankTest.scala | 30 +-
.../plan/batch/sql/RemoveCollationTest.scala | 4 +-
.../planner/plan/batch/sql/RemoveShuffleTest.scala | 4 +-
.../planner/plan/batch/sql/SetOperatorsTest.scala | 27 +-
.../planner/plan/batch/sql/SortLimitTest.scala | 2 +-
.../table/planner/plan/batch/sql/SortTest.scala | 2 +-
.../planner/plan/batch/sql/SubplanReuseTest.scala | 4 +-
.../planner/plan/batch/sql/TableScanTest.scala | 43 +-
.../planner/plan/batch/sql/TableSinkTest.scala | 8 +-
.../planner/plan/batch/sql/TableSourceTest.scala | 4 +-
.../table/planner/plan/batch/sql/UnionTest.scala | 4 +-
.../table/planner/plan/batch/sql/ValuesTest.scala | 2 +-
.../plan/batch/sql/WindowTableFunctionTest.scala | 38 +-
.../plan/batch/sql/agg/AggregateTestBase.scala | 48 +-
.../plan/batch/sql/agg/GroupWindowTest.scala | 153 +--
.../plan/batch/sql/agg/GroupingSetsTest.scala | 6 +-
.../plan/batch/sql/agg/HashAggregateTest.scala | 34 +-
.../plan/batch/sql/agg/OverAggregateTest.scala | 30 +-
.../plan/batch/sql/agg/SortAggregateTest.scala | 14 +-
.../batch/sql/join/BroadcastHashJoinTest.scala | 95 +-
.../sql/join/BroadcastHashSemiAntiJoinTest.scala | 125 +-
.../plan/batch/sql/join/JoinReorderTest.scala | 6 +-
.../planner/plan/batch/sql/join/JoinTestBase.scala | 18 +-
.../plan/batch/sql/join/LookupJoinTest.scala | 108 +-
.../plan/batch/sql/join/NestedLoopJoinTest.scala | 4 +-
.../sql/join/NestedLoopSemiAntiJoinTest.scala | 4 +-
.../plan/batch/sql/join/SemiAntiJoinTest.scala | 2 +-
.../plan/batch/sql/join/SemiAntiJoinTestBase.scala | 3 +-
.../plan/batch/sql/join/ShuffledHashJoinTest.scala | 71 +-
.../sql/join/ShuffledHashSemiAntiJoinTest.scala | 113 +-
.../plan/batch/sql/join/SingleRowJoinTest.scala | 2 +-
.../plan/batch/sql/join/SortMergeJoinTest.scala | 71 +-
.../batch/sql/join/SortMergeSemiAntiJoinTest.scala | 113 +-
.../batch/sql/join/TemporalFunctionJoinTest.scala | 30 +-
.../plan/batch/sql/join/TemporalJoinTest.scala | 25 +-
.../planner/plan/batch/table/AggregateTest.scala | 2 +-
.../table/planner/plan/batch/table/CalcTest.scala | 2 +-
.../plan/batch/table/ColumnFunctionsTest.scala | 2 +-
.../planner/plan/batch/table/CorrelateTest.scala | 2 +-
.../planner/plan/batch/table/GroupWindowTest.scala | 18 +-
.../table/planner/plan/batch/table/JoinTest.scala | 18 +-
.../plan/batch/table/PythonAggregateTest.scala | 8 +-
.../planner/plan/batch/table/PythonCalcTest.scala | 4 +-
.../table/PythonGroupWindowAggregateTest.scala | 18 +-
.../table/PythonOverWindowAggregateTest.scala | 8 +-
.../plan/batch/table/SetOperatorsTest.scala | 2 +-
.../table/TemporalTableFunctionJoinTest.scala | 18 +-
.../table/validation/AggregateValidationTest.scala | 142 +-
.../table/validation/CalcValidationTest.scala | 72 +-
.../table/validation/CorrelateValidationTest.scala | 18 +-
.../validation/GroupWindowValidationTest.scala | 142 +-
.../table/validation/JoinValidationTest.scala | 79 +-
.../validation/OverWindowValidationTest.scala | 21 +-
.../validation/SetOperatorsValidationTest.scala | 38 +-
.../table/validation/SortValidationTest.scala | 18 +-
.../common/AggregateReduceGroupingTestBase.scala | 4 +-
.../plan/common/DistinctAggregateTestBase.scala | 10 +-
.../planner/plan/common/JoinReorderTestBase.scala | 58 +-
.../planner/plan/common/PartialInsertTest.scala | 78 +-
.../planner/plan/common/TableFactoryTest.scala | 19 +-
.../table/planner/plan/common/UnnestTestBase.scala | 2 +-
.../planner/plan/common/ViewsExpandingTest.scala | 57 +-
.../table/planner/plan/hint/OptionsHintTest.scala | 57 +-
.../logical/AggregateReduceGroupingRuleTest.scala | 4 +-
.../logical/CalcPruneAggregateCallRuleTest.scala | 2 +
.../CalcPythonCorrelateTransposeRuleTest.scala | 4 +-
.../rules/logical/CalcRankTransposeRuleTest.scala | 4 +-
.../rules/logical/ConvertToNotInOrInRuleTest.scala | 4 +-
.../logical/CorrelateSortToRankRuleTest.scala | 4 +-
.../logical/DecomposeGroupingSetsRuleTest.scala | 8 +-
.../logical/ExpressionReductionRulesTest.scala | 2 +-
...AggregateExpandDistinctAggregatesRuleTest.scala | 4 +-
.../FlinkAggregateJoinTransposeRuleTest.scala | 4 +-
.../logical/FlinkAggregateRemoveRuleTest.scala | 4 +-
.../rules/logical/FlinkCalcMergeRuleTest.scala | 4 +-
.../logical/FlinkJoinPushExpressionsRuleTest.scala | 4 +-
.../logical/FlinkJoinToMultiJoinRuleTest.scala | 4 +-
.../rules/logical/FlinkLimit0RemoveRuleTest.scala | 4 +-
.../FlinkLogicalRankRuleForConstantRangeTest.scala | 2 +-
.../FlinkLogicalRankRuleForRangeEndTest.scala | 9 +-
.../rules/logical/FlinkPruneEmptyRulesTest.scala | 4 +-
.../FlinkSemiAntiJoinFilterTransposeRuleTest.scala | 4 +-
.../FlinkSemiAntiJoinJoinTransposeRuleTest.scala | 4 +-
...FlinkSemiAntiJoinProjectTransposeRuleTest.scala | 4 +-
.../JoinConditionEqualityTransferRuleTest.scala | 4 +-
.../logical/JoinConditionTypeCoerceRuleTest.scala | 4 +-
.../JoinDependentConditionDerivationRuleTest.scala | 4 +-
.../logical/JoinDeriveNullFilterRuleTest.scala | 4 +-
...lCorrelateToJoinFromTemporalTableRuleTest.scala | 55 +-
.../plan/rules/logical/LogicalUnnestRuleTest.scala | 4 +-
.../ProjectPruneAggregateCallRuleTest.scala | 2 +
.../ProjectSemiAntiJoinTransposeRuleTest.scala | 4 +-
...ojectWindowTableFunctionTransposeRuleTest.scala | 4 +-
.../logical/PruneAggregateCallRuleTestBase.scala | 4 +-
...shFilterIntoLegacyTableSourceScanRuleTest.scala | 4 +-
...ushLimitIntoLegacyTableSourceScanRuleTest.scala | 20 +-
...artitionIntoLegacyTableSourceScanRuleTest.scala | 48 +-
...hProjectIntoLegacyTableSourceScanRuleTest.scala | 4 +-
.../rules/logical/PythonCalcSplitRuleTest.scala | 4 +-
.../logical/PythonCorrelateSplitRuleTest.scala | 4 +-
.../rules/logical/PythonMapMergeRuleTest.scala | 4 +-
.../logical/RankNumberColumnRemoveRuleTest.scala | 4 +-
.../logical/RemoveSingleAggregateRuleTest.scala | 4 +-
.../ReplaceIntersectWithSemiJoinRuleTest.scala | 4 +-
.../logical/ReplaceMinusWithAntiJoinRuleTest.scala | 4 +-
.../logical/RewriteIntersectAllRuleTest.scala | 4 +-
.../rules/logical/RewriteMinusAllRuleTest.scala | 4 +-
.../RewriteMultiJoinConditionRuleTest.scala | 4 +-
.../logical/SimplifyFilterConditionRuleTest.scala | 4 +-
.../logical/SimplifyJoinConditionRuleTest.scala | 4 +-
.../rules/logical/SplitAggregateRuleTest.scala | 2 +-
...SplitPythonConditionFromCorrelateRuleTest.scala | 4 +-
.../SplitPythonConditionFromJoinRuleTest.scala | 4 +-
.../TemporalJoinRewriteWithUniqueKeyRuleTest.scala | 64 +-
.../rules/logical/WindowGroupReorderRuleTest.scala | 4 +-
.../subquery/FlinkRewriteSubQueryRuleTest.scala | 4 +-
.../logical/subquery/SubQueryAntiJoinTest.scala | 36 +-
.../logical/subquery/SubQuerySemiJoinTest.scala | 164 +--
.../SubqueryCorrelateVariablesValidationTest.scala | 23 +-
.../batch/EnforceLocalAggRuleTestBase.scala | 4 +-
.../batch/EnforceLocalHashAggRuleTest.scala | 4 +-
.../batch/EnforceLocalSortAggRuleTest.scala | 4 +-
.../RemoveRedundantLocalHashAggRuleTest.scala | 4 +-
.../batch/RemoveRedundantLocalRankRuleTest.scala | 4 +-
.../RemoveRedundantLocalSortAggRuleTest.scala | 4 +-
.../stream/ChangelogModeInferenceTest.scala | 4 +-
...xpandWindowTableFunctionTransposeRuleTest.scala | 4 +-
...signerChangelogNormalizeTransposeRuleTest.scala | 4 +-
.../table/planner/plan/stream/sql/CalcTest.scala | 10 +-
.../plan/stream/sql/DagOptimizationTest.scala | 2 +-
.../planner/plan/stream/sql/DeduplicateTest.scala | 4 +-
.../plan/stream/sql/FilterableSourceTest.scala | 4 +-
.../planner/plan/stream/sql/LegacySinkTest.scala | 18 +-
.../plan/stream/sql/LegacyTableSourceTest.scala | 4 +-
.../table/planner/plan/stream/sql/LimitTest.scala | 15 +-
.../plan/stream/sql/LimitableSourceTest.scala | 4 +-
.../plan/stream/sql/MatchRecognizeTest.scala | 52 +-
.../stream/sql/MiniBatchIntervalInferTest.scala | 4 +-
.../plan/stream/sql/ModifiedMonotonicityTest.scala | 6 +-
.../plan/stream/sql/NonDeterministicDagTest.scala | 1384 +++++++++++---------
.../plan/stream/sql/PartitionableSinkTest.scala | 17 +-
.../plan/stream/sql/PartitionableSourceTest.scala | 26 +-
.../table/planner/plan/stream/sql/RankTest.scala | 51 +-
.../stream/sql/RelTimeIndicatorConverterTest.scala | 2 +-
.../planner/plan/stream/sql/SetOperatorsTest.scala | 27 +-
.../planner/plan/stream/sql/SortLimitTest.scala | 2 +-
.../table/planner/plan/stream/sql/SortTest.scala | 2 +-
.../plan/stream/sql/SourceWatermarkTest.scala | 4 +-
.../planner/plan/stream/sql/SubplanReuseTest.scala | 4 +-
.../planner/plan/stream/sql/TableScanTest.scala | 84 +-
.../planner/plan/stream/sql/TableSinkTest.scala | 72 +-
.../planner/plan/stream/sql/TableSourceTest.scala | 16 +-
.../table/planner/plan/stream/sql/UnionTest.scala | 4 +-
.../table/planner/plan/stream/sql/UnnestTest.scala | 2 +-
.../table/planner/plan/stream/sql/ValuesTest.scala | 2 +-
.../plan/stream/sql/WindowDeduplicateTest.scala | 15 +-
.../planner/plan/stream/sql/WindowRankTest.scala | 61 +-
.../plan/stream/sql/WindowTableFunctionTest.scala | 20 +-
.../plan/stream/sql/agg/AggregateTest.scala | 24 +-
.../stream/sql/agg/DistinctAggregateTest.scala | 46 +-
.../plan/stream/sql/agg/GroupWindowTest.scala | 63 +-
.../plan/stream/sql/agg/GroupingSetsTest.scala | 13 +-
.../stream/sql/agg/IncrementalAggregateTest.scala | 12 +-
.../plan/stream/sql/agg/OverAggregateTest.scala | 31 +-
.../stream/sql/agg/TwoStageAggregateTest.scala | 4 +-
.../plan/stream/sql/agg/WindowAggregateTest.scala | 211 ++-
.../plan/stream/sql/join/IntervalJoinTest.scala | 31 +-
.../plan/stream/sql/join/JoinReorderTest.scala | 6 +-
.../planner/plan/stream/sql/join/JoinTest.scala | 2 +-
.../plan/stream/sql/join/LookupJoinTest.scala | 155 ++-
.../plan/stream/sql/join/SemiAntiJoinTest.scala | 2 +-
.../stream/sql/join/TemporalFunctionJoinTest.scala | 18 +-
.../plan/stream/sql/join/TemporalJoinTest.scala | 29 +-
.../plan/stream/sql/join/WindowJoinTest.scala | 21 +-
.../planner/plan/stream/table/AggregateTest.scala | 2 +-
.../table/planner/plan/stream/table/CalcTest.scala | 2 +-
.../plan/stream/table/ColumnFunctionsTest.scala | 2 +-
.../planner/plan/stream/table/CorrelateTest.scala | 2 +-
.../table/GroupWindowTableAggregateTest.scala | 2 +-
.../plan/stream/table/GroupWindowTest.scala | 2 +-
.../table/planner/plan/stream/table/JoinTest.scala | 2 +-
.../plan/stream/table/LegacyTableSourceTest.scala | 2 +-
.../plan/stream/table/OverAggregateTest.scala | 2 +-
.../plan/stream/table/PythonAggregateTest.scala | 32 +-
.../planner/plan/stream/table/PythonCalcTest.scala | 4 +-
.../table/PythonGroupWindowAggregateTest.scala | 14 +-
.../table/PythonOverWindowAggregateTest.scala | 2 +-
.../stream/table/PythonTableAggregateTest.scala | 2 +-
.../plan/stream/table/SetOperatorsTest.scala | 2 +-
.../plan/stream/table/TableAggregateTest.scala | 2 +-
.../plan/stream/table/TableSourceTest.scala | 20 +-
.../table/TemporalTableFunctionJoinTest.scala | 27 +-
.../plan/stream/table/TwoStageAggregateTest.scala | 4 +-
.../table/validation/AggregateValidationTest.scala | 114 +-
.../table/validation/CalcValidationTest.scala | 162 ++-
.../table/validation/CorrelateValidationTest.scala | 99 +-
.../GroupWindowTableAggregateValidationTest.scala | 44 +-
.../validation/GroupWindowValidationTest.scala | 301 +++--
.../validation/LegacyTableSinkValidationTest.scala | 67 +-
.../validation/OverWindowValidationTest.scala | 173 ++-
.../validation/SetOperatorsValidationTest.scala | 38 +-
.../validation/TableAggregateValidationTest.scala | 137 +-
.../TemporalTableJoinValidationTest.scala | 46 +-
.../flink/table/planner/utils/TableTestBase.scala | 100 +-
308 files changed, 5252 insertions(+), 4565 deletions(-)
