You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2022/02/23 16:08:17 UTC
[flink] branch master updated (e432723 -> 16be50f)
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 e432723 [FLINK-26319][table-planner] Fix expected exception in CastFunctionITCase
add 32700d9 [FLINK-25385][table-planner] Clean up RexNodeSerdeTest
add 4a1cdfd1 [hotfix][table-api-java] Fix typo in TableConfigOptions
add 7f332cf [hotfix][table] Deprecate legacy function stack classes
add 775010f [hotfix][table-planner] Improve exception message for ContextResolvedTable serde
add 9abec8c [FLINK-25385][table] Harden internal function handling
add 39c25f7 [FLINK-25385][table] Harden symbol handling
add db54a45 [FLINK-25385][table-planner] Harden the function serialization in JSON plan
add 16be50f [FLINK-25385][table-planner] Regenerate plans
No new revisions were added by this update.
Summary of changes:
.../generated/execution_config_configuration.html | 12 +-
.../generated/table_config_configuration.html | 2 +-
.../flink/table/api/config/TableConfigOptions.java | 2 +-
.../flink/table/utils/CatalogManagerMocks.java | 12 +-
.../functions/AggregateFunctionDefinition.java | 5 +-
.../table/functions/BuiltInFunctionDefinition.java | 6 +-
.../table/functions/ScalarFunctionDefinition.java | 3 +
.../TableAggregateFunctionDefinition.java | 5 +-
.../table/functions/TableFunctionDefinition.java | 5 +-
.../table/functions/UserDefinedFunctionHelper.java | 20 +-
.../functions/bridging/BridgingSqlAggFunction.java | 23 +-
.../functions/bridging/BridgingSqlFunction.java | 5 +-
.../planner/functions/sql/BuiltInSqlOperator.java | 14 +-
.../ContextResolvedTableJsonDeserializer.java | 37 +-
.../nodes/exec/serde/DataTypeJsonDeserializer.java | 15 +-
.../plan/nodes/exec/serde/JsonSerdeUtil.java | 11 +
.../exec/serde/LogicalTypeJsonDeserializer.java | 14 +-
.../exec/serde/RelDataTypeJsonDeserializer.java | 4 +
.../serde/ResolvedCatalogTableJsonSerializer.java | 2 +-
.../nodes/exec/serde/RexNodeJsonDeserializer.java | 621 +++++++++------
.../nodes/exec/serde/RexNodeJsonSerializer.java | 422 +++++++---
.../flink/table/planner/typeutils/SymbolUtil.java | 44 +-
.../functions/utils/ScalarSqlFunction.scala | 7 +-
.../planner/functions/utils/TableSqlFunction.scala | 6 +-
.../exec/serde/ContextResolvedTableSerdeTest.java | 8 +-
.../plan/nodes/exec/serde/JsonSerdeTestUtil.java | 46 +-
.../nodes/exec/serde/RexNodeJsonSerdeTest.java | 859 +++++++++++++++++++++
.../plan/nodes/exec/serde/RexNodeSerdeTest.java | 323 --------
.../nodes/exec/stream/CorrelateJsonPlanTest.java | 13 +-
.../utils/JavaUserDefinedScalarFunctions.java | 3 +-
.../table/planner/typeutils/SymbolUtilTest.java | 2 +-
.../CalcJsonPlanTest_jsonplan/testComplexCalc.out | 127 +--
.../CalcJsonPlanTest_jsonplan/testSimpleFilter.out | 9 +-
.../testCrossJoin.out | 16 +-
.../testCrossJoinOverrideParameters.out | 16 +-
.../testJoinWithFilter.out | 31 +-
.../testLeftOuterJoinWithLiteralTrue.out | 16 +-
.../testDeduplication.out | 16 +-
.../ExpandJsonPlanTest_jsonplan/testExpand.out | 50 +-
...tDistinctAggCalls[isMiniBatchEnabled=false].out | 54 +-
...stDistinctAggCalls[isMiniBatchEnabled=true].out | 54 +-
...gCallsWithGroupBy[isMiniBatchEnabled=false].out | 36 +-
...ggCallsWithGroupBy[isMiniBatchEnabled=true].out | 36 +-
...AggWithoutGroupBy[isMiniBatchEnabled=false].out | 54 +-
...eAggWithoutGroupBy[isMiniBatchEnabled=true].out | 54 +-
...erDefinedAggCalls[isMiniBatchEnabled=false].out | 9 +-
...serDefinedAggCalls[isMiniBatchEnabled=true].out | 9 +-
.../testEventTimeHopWindow.out | 46 +-
.../testEventTimeSessionWindow.out | 46 +-
.../testEventTimeTumbleWindow.out | 46 +-
.../testProcTimeHopWindow.out | 54 +-
.../testProcTimeSessionWindow.out | 54 +-
.../testProcTimeTumbleWindow.out | 54 +-
.../testIncrementalAggregate.out | 16 +-
...lAggregateWithSumCountDistinctAndRetraction.out | 16 +-
.../testProcessingTimeInnerJoinWithOnClause.out | 140 +---
.../testRowTimeInnerJoinWithOnClause.out | 124 +--
.../testLeftJoinNonEqui.out | 9 +-
.../testJoinTemporalTable.out | 96 +--
...testJoinTemporalTableWithProjectionPushDown.out | 96 +--
.../testMatch.out | 114 +--
.../testProcTimeBoundedNonPartitionedRangeOver.out | 36 +-
.../testProcTimeBoundedPartitionedRangeOver.out | 63 +-
...undedPartitionedRowsOverWithBuiltinProctime.out | 43 +-
.../testProcTimeUnboundedPartitionedRangeOver.out | 52 +-
...stProctimeBoundedDistinctPartitionedRowOver.out | 52 +-
...edDistinctWithNonDistinctPartitionedRowOver.out | 79 +-
.../testRowTimeBoundedPartitionedRowsOver.out | 8 +-
.../testFilterPushDown.out | 9 +-
.../testPartitionPushDown.out | 9 +-
.../testWatermarkPushDown.out | 22 +-
.../testJoinTemporalFunction.out | 17 +-
.../testTemporalTableJoin.out | 17 +-
.../testSortProcessingTime.out | 54 +-
.../testSortRowTime.out | 46 +-
.../ValuesJsonPlanTest_jsonplan/testValues.out | 27 +-
.../testWatermarkAssigner.out | 22 +-
.../testDistinctSplitEnabled.out | 107 +--
.../testEventTimeCumulateWindow.out | 46 +-
.../testEventTimeCumulateWindowWithOffset.out | 46 +-
.../testEventTimeHopWindow.out | 46 +-
.../testEventTimeHopWindowWithOffset.out | 46 +-
.../testEventTimeTumbleWindow.out | 46 +-
.../testEventTimeTumbleWindowWithOffset.out | 46 +-
.../testProcTimeCumulateWindow.out | 54 +-
.../testProcTimeHopWindow.out | 54 +-
.../testProcTimeTumbleWindow.out | 54 +-
.../testEventTimeTumbleWindow.out | 92 +--
.../testFollowedByWindowDeduplicate.out | 54 +-
.../testFollowedByWindowJoin.out | 110 +--
.../testFollowedByWindowRank.out | 54 +-
.../testIndividualWindowTVF.out | 46 +-
.../testIndividualWindowTVFProcessingTime.out | 54 +-
.../flink/table/planner/utils/TableTestBase.scala | 27 +-
tools/maven/suppressions.xml | 2 +-
95 files changed, 2704 insertions(+), 2885 deletions(-)
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/RexNodeJsonSerdeTest.java
delete mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/RexNodeSerdeTest.java