This is an automated email from the ASF dual-hosted git repository.
shengkai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 742685b76c7 [FLINK-30921][ci] Adds mirrors instead of relying on a
single source for Ubuntu packages
add 333e023196d [FLINK-31917][table-planner] Fix the idempotence lost in
JsonSerDe round trip for AggregateCall and RexNode (#22478)
No new revisions were added by this update.
Summary of changes:
.../exec/serde/AggregateCallJsonDeserializer.java | 4 +-
.../nodes/exec/serde/RexNodeJsonSerializer.java | 39 ++---
.../nodes/exec/serde/AggregateCallSerdeTest.java | 158 +++++++++++++++++++++
.../plan/nodes/exec/serde/JsonSerdeTestUtil.java | 1 +
.../nodes/exec/serde/RexNodeJsonSerdeTest.java | 11 +-
.../flink/table/planner/utils/JsonTestUtils.java | 5 +
.../CalcJsonPlanTest_jsonplan/testComplexCalc.out | 14 +-
.../CalcJsonPlanTest_jsonplan/testSimpleFilter.out | 4 +-
.../ExpandJsonPlanTest_jsonplan/testExpand.out | 14 +-
...tDistinctAggCalls[isMiniBatchEnabled=false].out | 4 +-
...stDistinctAggCalls[isMiniBatchEnabled=true].out | 4 +-
...gCallsWithGroupBy[isMiniBatchEnabled=false].out | 4 +-
...ggCallsWithGroupBy[isMiniBatchEnabled=true].out | 4 +-
...AggWithoutGroupBy[isMiniBatchEnabled=false].out | 4 +-
...eAggWithoutGroupBy[isMiniBatchEnabled=true].out | 4 +-
...erDefinedAggCalls[isMiniBatchEnabled=false].out | 6 +-
...serDefinedAggCalls[isMiniBatchEnabled=true].out | 6 +-
.../testIncrementalAggregate.out | 4 +-
...lAggregateWithSumCountDistinctAndRetraction.out | 4 +-
.../testMatch.out | 8 +-
.../testProcTimeBoundedPartitionedRangeOver.out | 4 +-
...undedPartitionedRowsOverWithBuiltinProctime.out | 6 +-
.../testProcTimeUnboundedPartitionedRangeOver.out | 4 +-
...stProctimeBoundedDistinctPartitionedRowOver.out | 6 +-
...edDistinctWithNonDistinctPartitionedRowOver.out | 8 +-
.../testRowTimeBoundedPartitionedRowsOver.out | 4 +-
.../testPythonFunctionInWhereClause.out | 4 +-
.../testJoinWithFilter.out | 4 +-
.../tesPythonAggCallsWithGroupBy.out | 4 +-
.../testEventTimeHopWindow.out | 4 +-
.../testEventTimeSessionWindow.out | 4 +-
.../testEventTimeTumbleWindow.out | 4 +-
.../testProcTimeHopWindow.out | 4 +-
.../testProcTimeSessionWindow.out | 4 +-
.../testProcTimeTumbleWindow.out | 4 +-
...undedPartitionedRowsOverWithBuiltinProctime.out | 4 +-
.../testRowTimeBoundedPartitionedRowsOver.out | 4 +-
.../testFilterPushDown.out | 4 +-
.../ValuesJsonPlanTest_jsonplan/testValues.out | 10 +-
.../testDistinctSplitEnabled.out | 4 +-
.../testFollowedByWindowJoin.out | 6 +-
.../flink/table/planner/utils/TableTestBase.scala | 19 ++-
42 files changed, 295 insertions(+), 126 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/AggregateCallSerdeTest.java
