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/03/26 06:20:19 UTC
[flink] branch master updated (330aae0 -> 84723ee)
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 330aae0 [FLINK-26847][python] Ensure command line option '-py' works in YARN application mode
add b0b92cb [hotfix][core] Add method to get all ConfigOptions from an "Options" class
add b8cdb8d [hotfix][table-planner] Remove consumed options not affecting the topology.
add bc11450 [FLINK-26075][table-planner] Persist node configuration to JSON plan
new 84723ee [FLINK-26075][table-planner][test] Regenerate JSON plans
The 1 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:
.../apache/flink/configuration/ConfigUtils.java | 23 ++
.../table/planner/plan/nodes/exec/ExecNode.java | 1 +
.../planner/plan/nodes/exec/ExecNodeBase.java | 21 +-
.../planner/plan/nodes/exec/ExecNodeConfig.java | 8 +-
.../planner/plan/nodes/exec/ExecNodeContext.java | 30 ++-
.../exec/batch/BatchExecBoundedStreamScan.java | 3 +
.../plan/nodes/exec/batch/BatchExecCalc.java | 3 +
.../plan/nodes/exec/batch/BatchExecCorrelate.java | 3 +
.../plan/nodes/exec/batch/BatchExecExchange.java | 8 +-
.../plan/nodes/exec/batch/BatchExecExpand.java | 3 +
.../nodes/exec/batch/BatchExecHashAggregate.java | 3 +
.../plan/nodes/exec/batch/BatchExecHashJoin.java | 3 +
.../exec/batch/BatchExecHashWindowAggregate.java | 3 +
.../plan/nodes/exec/batch/BatchExecLegacySink.java | 3 +
.../exec/batch/BatchExecLegacyTableSourceScan.java | 4 +
.../plan/nodes/exec/batch/BatchExecLimit.java | 3 +
.../plan/nodes/exec/batch/BatchExecLookupJoin.java | 3 +
.../nodes/exec/batch/BatchExecMultipleInput.java | 3 +
.../nodes/exec/batch/BatchExecNestedLoopJoin.java | 3 +
.../nodes/exec/batch/BatchExecOverAggregate.java | 3 +
.../exec/batch/BatchExecOverAggregateBase.java | 10 +-
.../plan/nodes/exec/batch/BatchExecPythonCalc.java | 3 +
.../nodes/exec/batch/BatchExecPythonCorrelate.java | 3 +
.../exec/batch/BatchExecPythonGroupAggregate.java | 4 +
.../batch/BatchExecPythonGroupWindowAggregate.java | 4 +
.../exec/batch/BatchExecPythonOverAggregate.java | 3 +
.../plan/nodes/exec/batch/BatchExecRank.java | 3 +
.../plan/nodes/exec/batch/BatchExecSink.java | 3 +
.../plan/nodes/exec/batch/BatchExecSort.java | 3 +
.../nodes/exec/batch/BatchExecSortAggregate.java | 3 +
.../plan/nodes/exec/batch/BatchExecSortLimit.java | 3 +
.../nodes/exec/batch/BatchExecSortMergeJoin.java | 3 +
.../exec/batch/BatchExecSortWindowAggregate.java | 3 +
.../nodes/exec/batch/BatchExecTableSourceScan.java | 7 +-
.../plan/nodes/exec/batch/BatchExecUnion.java | 7 +-
.../plan/nodes/exec/batch/BatchExecValues.java | 8 +-
.../exec/batch/BatchExecWindowTableFunction.java | 3 +
.../plan/nodes/exec/common/CommonExecCalc.java | 4 +-
.../nodes/exec/common/CommonExecCorrelate.java | 4 +-
.../plan/nodes/exec/common/CommonExecExchange.java | 4 +-
.../plan/nodes/exec/common/CommonExecExpand.java | 4 +-
.../nodes/exec/common/CommonExecLegacySink.java | 10 +-
.../common/CommonExecLegacyTableSourceScan.java | 4 +-
.../nodes/exec/common/CommonExecLookupJoin.java | 4 +-
.../nodes/exec/common/CommonExecPythonCalc.java | 4 +-
.../exec/common/CommonExecPythonCorrelate.java | 4 +-
.../plan/nodes/exec/common/CommonExecSink.java | 3 +-
.../exec/common/CommonExecTableSourceScan.java | 3 +-
.../plan/nodes/exec/common/CommonExecUnion.java | 4 +-
.../plan/nodes/exec/common/CommonExecValues.java | 4 +-
.../exec/common/CommonExecWindowTableFunction.java | 4 +-
.../processor/ForwardHashExchangeProcessor.java | 32 ++-
.../MultipleInputNodeCreationProcessor.java | 38 ++-
.../utils/InputPriorityConflictResolver.java | 19 +-
...zer.java => ConfigurationJsonDeserializer.java} | 27 ++-
...lizer.java => ConfigurationJsonSerializer.java} | 21 +-
.../serde/ConfigurationJsonSerializerFilter.java | 28 ++-
.../plan/nodes/exec/serde/JsonSerdeUtil.java | 3 +
.../nodes/exec/stream/StreamExecAggregateBase.java | 4 +-
.../plan/nodes/exec/stream/StreamExecCalc.java | 5 +
.../exec/stream/StreamExecChangelogNormalize.java | 7 +-
.../nodes/exec/stream/StreamExecCorrelate.java | 5 +
.../exec/stream/StreamExecDataStreamScan.java | 3 +
.../nodes/exec/stream/StreamExecDeduplicate.java | 6 +-
.../exec/stream/StreamExecDropUpdateBefore.java | 10 +-
.../plan/nodes/exec/stream/StreamExecExchange.java | 11 +-
.../plan/nodes/exec/stream/StreamExecExpand.java | 5 +
.../stream/StreamExecGlobalGroupAggregate.java | 13 +-
.../stream/StreamExecGlobalWindowAggregate.java | 7 +-
.../exec/stream/StreamExecGroupAggregate.java | 12 +-
.../exec/stream/StreamExecGroupTableAggregate.java | 4 +
.../stream/StreamExecGroupWindowAggregate.java | 7 +-
.../StreamExecIncrementalGroupAggregate.java | 13 +-
.../nodes/exec/stream/StreamExecIntervalJoin.java | 5 +-
.../plan/nodes/exec/stream/StreamExecJoin.java | 6 +-
.../nodes/exec/stream/StreamExecLegacySink.java | 3 +
.../stream/StreamExecLegacyTableSourceScan.java | 4 +
.../plan/nodes/exec/stream/StreamExecLimit.java | 7 +-
.../exec/stream/StreamExecLocalGroupAggregate.java | 7 +-
.../stream/StreamExecLocalWindowAggregate.java | 7 +-
.../nodes/exec/stream/StreamExecLookupJoin.java | 5 +
.../plan/nodes/exec/stream/StreamExecMatch.java | 5 +-
.../exec/stream/StreamExecMiniBatchAssigner.java | 6 +-
.../nodes/exec/stream/StreamExecMultipleInput.java | 7 +-
.../nodes/exec/stream/StreamExecOverAggregate.java | 7 +-
.../nodes/exec/stream/StreamExecPythonCalc.java | 6 +-
.../exec/stream/StreamExecPythonCorrelate.java | 5 +
.../stream/StreamExecPythonGroupAggregate.java | 7 +-
.../StreamExecPythonGroupTableAggregate.java | 4 +
.../StreamExecPythonGroupWindowAggregate.java | 10 +-
.../exec/stream/StreamExecPythonOverAggregate.java | 10 +-
.../plan/nodes/exec/stream/StreamExecRank.java | 8 +-
.../plan/nodes/exec/stream/StreamExecSink.java | 6 +-
.../plan/nodes/exec/stream/StreamExecSort.java | 3 +
.../nodes/exec/stream/StreamExecSortLimit.java | 7 +-
.../exec/stream/StreamExecTableSourceScan.java | 10 +-
.../nodes/exec/stream/StreamExecTemporalJoin.java | 7 +-
.../nodes/exec/stream/StreamExecTemporalSort.java | 6 +-
.../plan/nodes/exec/stream/StreamExecUnion.java | 10 +-
.../plan/nodes/exec/stream/StreamExecValues.java | 11 +-
.../exec/stream/StreamExecWatermarkAssigner.java | 7 +-
.../exec/stream/StreamExecWindowAggregate.java | 6 +-
.../exec/stream/StreamExecWindowAggregateBase.java | 4 +-
.../exec/stream/StreamExecWindowDeduplicate.java | 6 +-
.../nodes/exec/stream/StreamExecWindowJoin.java | 6 +-
.../nodes/exec/stream/StreamExecWindowRank.java | 6 +-
.../exec/stream/StreamExecWindowTableFunction.java | 14 +-
.../planner/plan/utils/ExecNodeMetadataUtil.java | 79 +++++++
.../batch/BatchPhysicalBoundedStreamScan.scala | 2 +
.../nodes/physical/batch/BatchPhysicalCalc.scala | 4 +-
.../physical/batch/BatchPhysicalCorrelate.scala | 4 +-
.../physical/batch/BatchPhysicalExchange.scala | 1 +
.../nodes/physical/batch/BatchPhysicalExpand.scala | 7 +-
.../batch/BatchPhysicalHashAggregate.scala | 4 +-
.../physical/batch/BatchPhysicalHashJoin.scala | 25 +-
.../batch/BatchPhysicalHashWindowAggregate.scala | 5 +-
.../physical/batch/BatchPhysicalLegacySink.scala | 5 +-
.../batch/BatchPhysicalLegacyTableSourceScan.scala | 2 +
.../nodes/physical/batch/BatchPhysicalLimit.scala | 16 +-
.../batch/BatchPhysicalLocalHashAggregate.scala | 7 +-
.../BatchPhysicalLocalHashWindowAggregate.scala | 5 +-
.../batch/BatchPhysicalLocalSortAggregate.scala | 7 +-
.../BatchPhysicalLocalSortWindowAggregate.scala | 5 +-
.../physical/batch/BatchPhysicalLookupJoin.scala | 2 +
.../batch/BatchPhysicalNestedLoopJoin.scala | 5 +-
.../batch/BatchPhysicalOverAggregate.scala | 5 +-
.../physical/batch/BatchPhysicalPythonCalc.scala | 2 +
.../batch/BatchPhysicalPythonCorrelate.scala | 7 +-
.../batch/BatchPhysicalPythonGroupAggregate.scala | 8 +-
.../BatchPhysicalPythonGroupWindowAggregate.scala | 5 +-
.../batch/BatchPhysicalPythonOverAggregate.scala | 5 +-
.../nodes/physical/batch/BatchPhysicalRank.scala | 4 +-
.../nodes/physical/batch/BatchPhysicalSink.scala | 8 +-
.../nodes/physical/batch/BatchPhysicalSort.scala | 7 +-
.../batch/BatchPhysicalSortAggregate.scala | 4 +-
.../physical/batch/BatchPhysicalSortLimit.scala | 7 +-
.../batch/BatchPhysicalSortMergeJoin.scala | 5 +-
.../batch/BatchPhysicalSortWindowAggregate.scala | 5 +-
.../batch/BatchPhysicalTableSourceScan.scala | 2 +
.../nodes/physical/batch/BatchPhysicalUnion.scala | 7 +-
.../nodes/physical/batch/BatchPhysicalValues.scala | 5 +-
.../batch/BatchPhysicalWindowTableFunction.scala | 5 +-
.../nodes/physical/stream/StreamPhysicalCalc.scala | 2 +
.../stream/StreamPhysicalChangelogNormalize.scala | 2 +
.../physical/stream/StreamPhysicalCorrelate.scala | 4 +-
.../stream/StreamPhysicalDataStreamScan.scala | 2 +
.../stream/StreamPhysicalDeduplicate.scala | 7 +-
.../stream/StreamPhysicalDropUpdateBefore.scala | 7 +-
.../physical/stream/StreamPhysicalExchange.scala | 4 +-
.../physical/stream/StreamPhysicalExpand.scala | 7 +-
.../StreamPhysicalGlobalGroupAggregate.scala | 7 +-
.../StreamPhysicalGlobalWindowAggregate.scala | 4 +-
.../stream/StreamPhysicalGroupAggregate.scala | 7 +-
.../stream/StreamPhysicalGroupTableAggregate.scala | 7 +-
.../StreamPhysicalGroupWindowAggregate.scala | 5 +-
.../StreamPhysicalGroupWindowTableAggregate.scala | 5 +-
.../StreamPhysicalIncrementalGroupAggregate.scala | 7 +-
.../stream/StreamPhysicalIntervalJoin.scala | 12 +-
.../nodes/physical/stream/StreamPhysicalJoin.scala | 18 +-
.../physical/stream/StreamPhysicalLegacySink.scala | 5 +-
.../StreamPhysicalLegacyTableSourceScan.scala | 2 +
.../physical/stream/StreamPhysicalLimit.scala | 19 +-
.../stream/StreamPhysicalLocalGroupAggregate.scala | 7 +-
.../StreamPhysicalLocalWindowAggregate.scala | 4 +-
.../physical/stream/StreamPhysicalLookupJoin.scala | 2 +
.../physical/stream/StreamPhysicalMatch.scala | 7 +-
.../stream/StreamPhysicalMiniBatchAssigner.scala | 7 +-
.../stream/StreamPhysicalOverAggregate.scala | 7 +-
.../physical/stream/StreamPhysicalPythonCalc.scala | 4 +-
.../stream/StreamPhysicalPythonCorrelate.scala | 7 +-
.../StreamPhysicalPythonGroupAggregate.scala | 7 +-
.../StreamPhysicalPythonGroupTableAggregate.scala | 7 +-
.../StreamPhysicalPythonGroupWindowAggregate.scala | 5 +-
.../stream/StreamPhysicalPythonOverAggregate.scala | 7 +-
.../nodes/physical/stream/StreamPhysicalRank.scala | 5 +-
.../nodes/physical/stream/StreamPhysicalSink.scala | 5 +-
.../nodes/physical/stream/StreamPhysicalSort.scala | 5 +-
.../physical/stream/StreamPhysicalSortLimit.scala | 7 +-
.../stream/StreamPhysicalTableSourceScan.scala | 2 +
.../stream/StreamPhysicalTemporalJoin.scala | 2 +
.../stream/StreamPhysicalTemporalSort.scala | 5 +-
.../physical/stream/StreamPhysicalUnion.scala | 7 +-
.../physical/stream/StreamPhysicalValues.scala | 5 +-
.../stream/StreamPhysicalWatermarkAssigner.scala | 2 +
.../stream/StreamPhysicalWindowAggregate.scala | 4 +-
.../stream/StreamPhysicalWindowDeduplicate.scala | 5 +-
.../physical/stream/StreamPhysicalWindowJoin.scala | 2 +
.../physical/stream/StreamPhysicalWindowRank.scala | 5 +-
.../stream/StreamPhysicalWindowTableFunction.scala | 5 +-
.../apache/flink/table/api/CompiledPlanITCase.java | 51 +++-
.../utils/InputPriorityConflictResolverTest.java | 1 +
.../plan/utils/ExecNodeMetadataUtilTest.java | 256 ++++++++++++++++++---
.../test/resources/jsonplan/testGetJsonPlan.out | 6 +
.../CalcJsonPlanTest_jsonplan/testComplexCalc.out | 6 +
.../CalcJsonPlanTest_jsonplan/testSimpleFilter.out | 6 +
.../testSimpleProject.out | 6 +
.../testChangelogSource.out | 10 +
.../testUpsertSource.out | 10 +
.../testCrossJoin.out | 6 +
.../testCrossJoinOverrideParameters.out | 6 +
.../testJoinWithFilter.out | 6 +
.../testLeftOuterJoinWithLiteralTrue.out | 6 +
.../testDeduplication.out | 12 +
.../ExpandJsonPlanTest_jsonplan/testExpand.out | 14 ++
...tDistinctAggCalls[isMiniBatchEnabled=false].out | 10 +
...stDistinctAggCalls[isMiniBatchEnabled=true].out | 14 ++
...gCallsWithGroupBy[isMiniBatchEnabled=false].out | 10 +
...ggCallsWithGroupBy[isMiniBatchEnabled=true].out | 14 ++
...AggWithoutGroupBy[isMiniBatchEnabled=false].out | 10 +
...eAggWithoutGroupBy[isMiniBatchEnabled=true].out | 14 ++
...erDefinedAggCalls[isMiniBatchEnabled=false].out | 10 +
...serDefinedAggCalls[isMiniBatchEnabled=true].out | 10 +
.../testEventTimeHopWindow.out | 11 +
.../testEventTimeSessionWindow.out | 11 +
.../testEventTimeTumbleWindow.out | 11 +
.../testProcTimeHopWindow.out | 11 +
.../testProcTimeSessionWindow.out | 11 +
.../testProcTimeTumbleWindow.out | 11 +
.../testIncrementalAggregate.out | 18 ++
...lAggregateWithSumCountDistinctAndRetraction.out | 26 +++
.../testProcessingTimeInnerJoinWithOnClause.out | 6 +
.../testRowTimeInnerJoinWithOnClause.out | 6 +
.../JoinJsonPlanTest_jsonplan/testInnerJoin.out | 6 +
.../testInnerJoinWithEqualPk.out | 14 ++
.../testInnerJoinWithPk.out | 14 ++
.../testLeftJoinNonEqui.out | 6 +
.../LimitJsonPlanTest_jsonplan/testLimit.out | 9 +
.../testJoinTemporalTable.out | 6 +
...testJoinTemporalTableWithProjectionPushDown.out | 6 +
.../testMatch.out | 6 +
.../testProcTimeBoundedNonPartitionedRangeOver.out | 6 +
.../testProcTimeBoundedPartitionedRangeOver.out | 6 +
...undedPartitionedRowsOverWithBuiltinProctime.out | 6 +
.../testProcTimeUnboundedPartitionedRangeOver.out | 6 +
...stProctimeBoundedDistinctPartitionedRowOver.out | 6 +
...edDistinctWithNonDistinctPartitionedRowOver.out | 6 +
.../testRowTimeBoundedPartitionedRowsOver.out | 6 +
.../stream/RankJsonPlanTest_jsonplan/testRank.out | 9 +
.../testSortLimit.out | 9 +
.../testOverwrite.out | 6 +
.../testPartitioning.out | 6 +
.../testWritingMetadata.out | 6 +
.../testFilterPushDown.out | 6 +
.../testLimitPushDown.out | 9 +
.../testPartitionPushDown.out | 6 +
.../testProjectPushDown.out | 6 +
.../testReadingMetadata.out | 6 +
.../testWatermarkPushDown.out | 6 +
.../testJoinTemporalFunction.out | 6 +
.../testTemporalTableJoin.out | 6 +
.../testSortProcessingTime.out | 6 +
.../testSortRowTime.out | 6 +
.../UnionJsonPlanTest_jsonplan/testUnion.out | 6 +
.../ValuesJsonPlanTest_jsonplan/testValues.out | 6 +
.../testWatermarkAssigner.out | 6 +
.../testDistinctSplitEnabled.out | 18 ++
.../testEventTimeCumulateWindow.out | 12 +
.../testEventTimeCumulateWindowWithOffset.out | 12 +
.../testEventTimeHopWindow.out | 12 +
.../testEventTimeHopWindowWithOffset.out | 12 +
.../testEventTimeTumbleWindow.out | 12 +
.../testEventTimeTumbleWindowWithOffset.out | 12 +
.../testProcTimeCumulateWindow.out | 9 +
.../testProcTimeHopWindow.out | 9 +
.../testProcTimeTumbleWindow.out | 9 +
.../testEventTimeTumbleWindow.out | 21 ++
.../testFollowedByWindowDeduplicate.out | 12 +
.../testFollowedByWindowJoin.out | 15 ++
.../testFollowedByWindowRank.out | 12 +
.../testIndividualWindowTVF.out | 9 +
.../testIndividualWindowTVFProcessingTime.out | 9 +
271 files changed, 1965 insertions(+), 393 deletions(-)
copy flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/{ExecNodeGraphJsonDeserializer.java => ConfigurationJsonDeserializer.java} (65%)
copy flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/{ObjectIdentifierJsonSerializer.java => ConfigurationJsonSerializer.java} (68%)
copy flink-yarn/src/main/java/org/apache/flink/yarn/cli/FallbackYarnSessionCli.java => flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ConfigurationJsonSerializerFilter.java (59%)
[flink] 01/01: [FLINK-26075][table-planner][test] Regenerate JSON plans
Posted by tw...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 84723eea4e7ddae846092ca8bb0905a7b9d6dc6a
Author: Marios Trivyzas <ma...@gmail.com>
AuthorDate: Thu Mar 24 16:02:17 2022 +0200
[FLINK-26075][table-planner][test] Regenerate JSON plans
This closes #19232.
---
.../test/resources/jsonplan/testGetJsonPlan.out | 6 +++++
.../CalcJsonPlanTest_jsonplan/testComplexCalc.out | 6 +++++
.../CalcJsonPlanTest_jsonplan/testSimpleFilter.out | 6 +++++
.../testSimpleProject.out | 6 +++++
.../testChangelogSource.out | 10 +++++++++
.../testUpsertSource.out | 10 +++++++++
.../testCrossJoin.out | 6 +++++
.../testCrossJoinOverrideParameters.out | 6 +++++
.../testJoinWithFilter.out | 6 +++++
.../testLeftOuterJoinWithLiteralTrue.out | 6 +++++
.../testDeduplication.out | 12 ++++++++++
.../ExpandJsonPlanTest_jsonplan/testExpand.out | 14 ++++++++++++
...tDistinctAggCalls[isMiniBatchEnabled=false].out | 10 +++++++++
...stDistinctAggCalls[isMiniBatchEnabled=true].out | 14 ++++++++++++
...gCallsWithGroupBy[isMiniBatchEnabled=false].out | 10 +++++++++
...ggCallsWithGroupBy[isMiniBatchEnabled=true].out | 14 ++++++++++++
...AggWithoutGroupBy[isMiniBatchEnabled=false].out | 10 +++++++++
...eAggWithoutGroupBy[isMiniBatchEnabled=true].out | 14 ++++++++++++
...erDefinedAggCalls[isMiniBatchEnabled=false].out | 10 +++++++++
...serDefinedAggCalls[isMiniBatchEnabled=true].out | 10 +++++++++
.../testEventTimeHopWindow.out | 11 +++++++++
.../testEventTimeSessionWindow.out | 11 +++++++++
.../testEventTimeTumbleWindow.out | 11 +++++++++
.../testProcTimeHopWindow.out | 11 +++++++++
.../testProcTimeSessionWindow.out | 11 +++++++++
.../testProcTimeTumbleWindow.out | 11 +++++++++
.../testIncrementalAggregate.out | 18 +++++++++++++++
...lAggregateWithSumCountDistinctAndRetraction.out | 26 ++++++++++++++++++++++
.../testProcessingTimeInnerJoinWithOnClause.out | 6 +++++
.../testRowTimeInnerJoinWithOnClause.out | 6 +++++
.../JoinJsonPlanTest_jsonplan/testInnerJoin.out | 6 +++++
.../testInnerJoinWithEqualPk.out | 14 ++++++++++++
.../testInnerJoinWithPk.out | 14 ++++++++++++
.../testLeftJoinNonEqui.out | 6 +++++
.../LimitJsonPlanTest_jsonplan/testLimit.out | 9 ++++++++
.../testJoinTemporalTable.out | 6 +++++
...testJoinTemporalTableWithProjectionPushDown.out | 6 +++++
.../testMatch.out | 6 +++++
.../testProcTimeBoundedNonPartitionedRangeOver.out | 6 +++++
.../testProcTimeBoundedPartitionedRangeOver.out | 6 +++++
...undedPartitionedRowsOverWithBuiltinProctime.out | 6 +++++
.../testProcTimeUnboundedPartitionedRangeOver.out | 6 +++++
...stProctimeBoundedDistinctPartitionedRowOver.out | 6 +++++
...edDistinctWithNonDistinctPartitionedRowOver.out | 6 +++++
.../testRowTimeBoundedPartitionedRowsOver.out | 6 +++++
.../stream/RankJsonPlanTest_jsonplan/testRank.out | 9 ++++++++
.../testSortLimit.out | 9 ++++++++
.../testOverwrite.out | 6 +++++
.../testPartitioning.out | 6 +++++
.../testWritingMetadata.out | 6 +++++
.../testFilterPushDown.out | 6 +++++
.../testLimitPushDown.out | 9 ++++++++
.../testPartitionPushDown.out | 6 +++++
.../testProjectPushDown.out | 6 +++++
.../testReadingMetadata.out | 6 +++++
.../testWatermarkPushDown.out | 6 +++++
.../testJoinTemporalFunction.out | 6 +++++
.../testTemporalTableJoin.out | 6 +++++
.../testSortProcessingTime.out | 6 +++++
.../testSortRowTime.out | 6 +++++
.../UnionJsonPlanTest_jsonplan/testUnion.out | 6 +++++
.../ValuesJsonPlanTest_jsonplan/testValues.out | 6 +++++
.../testWatermarkAssigner.out | 6 +++++
.../testDistinctSplitEnabled.out | 18 +++++++++++++++
.../testEventTimeCumulateWindow.out | 12 ++++++++++
.../testEventTimeCumulateWindowWithOffset.out | 12 ++++++++++
.../testEventTimeHopWindow.out | 12 ++++++++++
.../testEventTimeHopWindowWithOffset.out | 12 ++++++++++
.../testEventTimeTumbleWindow.out | 12 ++++++++++
.../testEventTimeTumbleWindowWithOffset.out | 12 ++++++++++
.../testProcTimeCumulateWindow.out | 9 ++++++++
.../testProcTimeHopWindow.out | 9 ++++++++
.../testProcTimeTumbleWindow.out | 9 ++++++++
.../testEventTimeTumbleWindow.out | 21 +++++++++++++++++
.../testFollowedByWindowDeduplicate.out | 12 ++++++++++
.../testFollowedByWindowJoin.out | 15 +++++++++++++
.../testFollowedByWindowRank.out | 12 ++++++++++
.../testIndividualWindowTVF.out | 9 ++++++++
.../testIndividualWindowTVFProcessingTime.out | 9 ++++++++
79 files changed, 729 insertions(+)
diff --git a/flink-table/flink-table-planner/src/test/resources/jsonplan/testGetJsonPlan.out b/flink-table/flink-table-planner/src/test/resources/jsonplan/testGetJsonPlan.out
index 1bc32ad..281372b 100644
--- a/flink-table/flink-table-planner/src/test/resources/jsonplan/testGetJsonPlan.out
+++ b/flink-table/flink-table-planner/src/test/resources/jsonplan/testGetJsonPlan.out
@@ -40,6 +40,12 @@
{
"id": 2,
"type": "stream-exec-sink_1",
+ "configuration":{
+ "table.exec.sink.keyed-shuffle":"AUTO",
+ "table.exec.sink.not-null-enforcer":"ERROR",
+ "table.exec.sink.type-length-enforcer":"IGNORE",
+ "table.exec.sink.upsert-materialize":"AUTO"
+ },
"dynamicTableSink": {
"table": {
"identifier": "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CalcJsonPlanTest_jsonplan/testComplexCalc.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CalcJsonPlanTest_jsonplan/testComplexCalc.out
index 9ac59d9..4dcf71a 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CalcJsonPlanTest_jsonplan/testComplexCalc.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CalcJsonPlanTest_jsonplan/testComplexCalc.out
@@ -208,6 +208,12 @@
}, {
"id" : 3,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CalcJsonPlanTest_jsonplan/testSimpleFilter.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CalcJsonPlanTest_jsonplan/testSimpleFilter.out
index c104d9a4..6028828 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CalcJsonPlanTest_jsonplan/testSimpleFilter.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CalcJsonPlanTest_jsonplan/testSimpleFilter.out
@@ -85,6 +85,12 @@
}, {
"id" : 3,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CalcJsonPlanTest_jsonplan/testSimpleProject.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CalcJsonPlanTest_jsonplan/testSimpleProject.out
index 2ae314d..13806b7 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CalcJsonPlanTest_jsonplan/testSimpleProject.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CalcJsonPlanTest_jsonplan/testSimpleProject.out
@@ -46,6 +46,12 @@
}, {
"id" : 2,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ChangelogSourceJsonPlanTest_jsonplan/testChangelogSource.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ChangelogSourceJsonPlanTest_jsonplan/testChangelogSource.out
index 63449c0..1f4ca9d 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ChangelogSourceJsonPlanTest_jsonplan/testChangelogSource.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ChangelogSourceJsonPlanTest_jsonplan/testChangelogSource.out
@@ -77,6 +77,10 @@
}, {
"id" : 4,
"type" : "stream-exec-changelog-normalize_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1"
+ },
"uniqueKeys" : [ 0, 1 ],
"generateUpdateBefore" : true,
"inputProperties" : [ {
@@ -91,6 +95,12 @@
}, {
"id" : 5,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ChangelogSourceJsonPlanTest_jsonplan/testUpsertSource.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ChangelogSourceJsonPlanTest_jsonplan/testUpsertSource.out
index b89ceb2..81bd0cc 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ChangelogSourceJsonPlanTest_jsonplan/testUpsertSource.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ChangelogSourceJsonPlanTest_jsonplan/testUpsertSource.out
@@ -65,6 +65,10 @@
}, {
"id" : 3,
"type" : "stream-exec-changelog-normalize_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1"
+ },
"uniqueKeys" : [ 0, 1 ],
"generateUpdateBefore" : true,
"inputProperties" : [ {
@@ -79,6 +83,12 @@
}, {
"id" : 4,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CorrelateJsonPlanTest_jsonplan/testCrossJoin.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CorrelateJsonPlanTest_jsonplan/testCrossJoin.out
index ba4d03d..8930780 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CorrelateJsonPlanTest_jsonplan/testCrossJoin.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CorrelateJsonPlanTest_jsonplan/testCrossJoin.out
@@ -87,6 +87,12 @@
}, {
"id" : 4,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CorrelateJsonPlanTest_jsonplan/testCrossJoinOverrideParameters.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CorrelateJsonPlanTest_jsonplan/testCrossJoinOverrideParameters.out
index c8def35..9e69b43 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CorrelateJsonPlanTest_jsonplan/testCrossJoinOverrideParameters.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CorrelateJsonPlanTest_jsonplan/testCrossJoinOverrideParameters.out
@@ -91,6 +91,12 @@
}, {
"id" : 4,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CorrelateJsonPlanTest_jsonplan/testJoinWithFilter.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CorrelateJsonPlanTest_jsonplan/testJoinWithFilter.out
index c31983b..033efb8 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CorrelateJsonPlanTest_jsonplan/testJoinWithFilter.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CorrelateJsonPlanTest_jsonplan/testJoinWithFilter.out
@@ -101,6 +101,12 @@
}, {
"id" : 4,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CorrelateJsonPlanTest_jsonplan/testLeftOuterJoinWithLiteralTrue.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CorrelateJsonPlanTest_jsonplan/testLeftOuterJoinWithLiteralTrue.out
index 8f15169..7c3ebe8 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CorrelateJsonPlanTest_jsonplan/testLeftOuterJoinWithLiteralTrue.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/CorrelateJsonPlanTest_jsonplan/testLeftOuterJoinWithLiteralTrue.out
@@ -87,6 +87,12 @@
}, {
"id" : 4,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/DeduplicationJsonPlanTest_jsonplan/testDeduplication.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/DeduplicationJsonPlanTest_jsonplan/testDeduplication.out
index 9829b7c..f2c4a58 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/DeduplicationJsonPlanTest_jsonplan/testDeduplication.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/DeduplicationJsonPlanTest_jsonplan/testDeduplication.out
@@ -154,6 +154,12 @@
}, {
"id" : 4,
"type" : "stream-exec-deduplicate_1",
+ "configuration" : {
+ "table.exec.deduplicate.insert-update-after-sensitive-enabled" : "true",
+ "table.exec.deduplicate.mini-batch.compact-changes-enabled" : "false",
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1"
+ },
"uniqueKeys" : [ 2 ],
"isRowtime" : false,
"keepLastRow" : false,
@@ -223,6 +229,12 @@
}, {
"id" : 6,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`sink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ExpandJsonPlanTest_jsonplan/testExpand.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ExpandJsonPlanTest_jsonplan/testExpand.out
index 04d059e..3982472 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ExpandJsonPlanTest_jsonplan/testExpand.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ExpandJsonPlanTest_jsonplan/testExpand.out
@@ -232,6 +232,10 @@
}, {
"id" : 6,
"type" : "stream-exec-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1"
+ },
"grouping" : [ 0, 3, 4 ],
"aggCalls" : [ {
"name" : null,
@@ -281,6 +285,10 @@
}, {
"id" : 8,
"type" : "stream-exec-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : null,
@@ -316,6 +324,12 @@
}, {
"id" : 9,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testDistinctAggCalls[isMiniBatchEnabled=false].out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testDistinctAggCalls[isMiniBatchEnabled=false].out
index 5a69103..52aad80 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testDistinctAggCalls[isMiniBatchEnabled=false].out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testDistinctAggCalls[isMiniBatchEnabled=false].out
@@ -94,6 +94,10 @@
}, {
"id" : 4,
"type" : "stream-exec-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "cnt_a1",
@@ -240,6 +244,12 @@
}, {
"id" : 6,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testDistinctAggCalls[isMiniBatchEnabled=true].out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testDistinctAggCalls[isMiniBatchEnabled=true].out
index d56ae50..bfef96f 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testDistinctAggCalls[isMiniBatchEnabled=true].out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testDistinctAggCalls[isMiniBatchEnabled=true].out
@@ -97,6 +97,10 @@
}, {
"id" : 4,
"type" : "stream-exec-local-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "true",
+ "table.exec.mini-batch.size" : "5"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "cnt_a1",
@@ -337,6 +341,10 @@
}, {
"id" : 6,
"type" : "stream-exec-global-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "true",
+ "table.exec.mini-batch.size" : "5"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "cnt_a1",
@@ -484,6 +492,12 @@
}, {
"id" : 8,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testSimpleAggCallsWithGroupBy[isMiniBatchEnabled=false].out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testSimpleAggCallsWithGroupBy[isMiniBatchEnabled=false].out
index 54e1aa4..4ca7313 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testSimpleAggCallsWithGroupBy[isMiniBatchEnabled=false].out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testSimpleAggCallsWithGroupBy[isMiniBatchEnabled=false].out
@@ -99,6 +99,10 @@
}, {
"id" : 4,
"type" : "stream-exec-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "cnt_a",
@@ -192,6 +196,12 @@
}, {
"id" : 6,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testSimpleAggCallsWithGroupBy[isMiniBatchEnabled=true].out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testSimpleAggCallsWithGroupBy[isMiniBatchEnabled=true].out
index 6d0adeb..b31d031 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testSimpleAggCallsWithGroupBy[isMiniBatchEnabled=true].out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testSimpleAggCallsWithGroupBy[isMiniBatchEnabled=true].out
@@ -102,6 +102,10 @@
}, {
"id" : 4,
"type" : "stream-exec-local-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "true",
+ "table.exec.mini-batch.size" : "5"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "cnt_a",
@@ -159,6 +163,10 @@
}, {
"id" : 6,
"type" : "stream-exec-global-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "true",
+ "table.exec.mini-batch.size" : "5"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "cnt_a",
@@ -253,6 +261,12 @@
}, {
"id" : 8,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testSimpleAggWithoutGroupBy[isMiniBatchEnabled=false].out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testSimpleAggWithoutGroupBy[isMiniBatchEnabled=false].out
index c8d7b01..ab5ecc9 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testSimpleAggWithoutGroupBy[isMiniBatchEnabled=false].out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testSimpleAggWithoutGroupBy[isMiniBatchEnabled=false].out
@@ -104,6 +104,10 @@
}, {
"id" : 4,
"type" : "stream-exec-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1"
+ },
"grouping" : [ ],
"aggCalls" : [ {
"name" : "avg_a",
@@ -216,6 +220,12 @@
}, {
"id" : 6,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testSimpleAggWithoutGroupBy[isMiniBatchEnabled=true].out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testSimpleAggWithoutGroupBy[isMiniBatchEnabled=true].out
index c53e463..8e9e1e6 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testSimpleAggWithoutGroupBy[isMiniBatchEnabled=true].out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testSimpleAggWithoutGroupBy[isMiniBatchEnabled=true].out
@@ -108,6 +108,10 @@
}, {
"id" : 4,
"type" : "stream-exec-local-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "true",
+ "table.exec.mini-batch.size" : "5"
+ },
"grouping" : [ ],
"aggCalls" : [ {
"name" : "avg_a",
@@ -173,6 +177,10 @@
}, {
"id" : 6,
"type" : "stream-exec-global-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "true",
+ "table.exec.mini-batch.size" : "5"
+ },
"grouping" : [ ],
"aggCalls" : [ {
"name" : "avg_a",
@@ -286,6 +294,12 @@
}, {
"id" : 8,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testUserDefinedAggCalls[isMiniBatchEnabled=false].out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testUserDefinedAggCalls[isMiniBatchEnabled=false].out
index cc12b89..1ce190c 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testUserDefinedAggCalls[isMiniBatchEnabled=false].out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testUserDefinedAggCalls[isMiniBatchEnabled=false].out
@@ -88,6 +88,10 @@
}, {
"id" : 4,
"type" : "stream-exec-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "a1",
@@ -182,6 +186,12 @@
}, {
"id" : 6,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testUserDefinedAggCalls[isMiniBatchEnabled=true].out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testUserDefinedAggCalls[isMiniBatchEnabled=true].out
index 41687d0..201e954 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testUserDefinedAggCalls[isMiniBatchEnabled=true].out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupAggregateJsonPlanTest_jsonplan/testUserDefinedAggCalls[isMiniBatchEnabled=true].out
@@ -104,6 +104,10 @@
}, {
"id" : 5,
"type" : "stream-exec-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "true",
+ "table.exec.mini-batch.size" : "5"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "a1",
@@ -198,6 +202,12 @@
}, {
"id" : 7,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindow.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindow.out
index aef0a94..ab0ae9d 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindow.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindow.out
@@ -200,6 +200,11 @@
}, {
"id" : 5,
"type" : "stream-exec-group-window-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1",
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$1",
@@ -259,6 +264,12 @@
}, {
"id" : 6,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testEventTimeSessionWindow.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testEventTimeSessionWindow.out
index a0a44cb..467b00f 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testEventTimeSessionWindow.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testEventTimeSessionWindow.out
@@ -200,6 +200,11 @@
}, {
"id" : 5,
"type" : "stream-exec-group-window-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1",
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$1",
@@ -257,6 +262,12 @@
}, {
"id" : 6,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out
index f41b8d2..d30a69a 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out
@@ -200,6 +200,11 @@
}, {
"id" : 5,
"type" : "stream-exec-group-window-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1",
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$3",
@@ -410,6 +415,12 @@
}, {
"id" : 7,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testProcTimeHopWindow.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testProcTimeHopWindow.out
index 1c9fbb7..68ecda4 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testProcTimeHopWindow.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testProcTimeHopWindow.out
@@ -287,6 +287,11 @@
}, {
"id" : 6,
"type" : "stream-exec-group-window-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1",
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$1",
@@ -338,6 +343,12 @@
}, {
"id" : 7,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testProcTimeSessionWindow.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testProcTimeSessionWindow.out
index b44c9c4..e07c84a 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testProcTimeSessionWindow.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testProcTimeSessionWindow.out
@@ -287,6 +287,11 @@
}, {
"id" : 6,
"type" : "stream-exec-group-window-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1",
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$1",
@@ -336,6 +341,12 @@
}, {
"id" : 7,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testProcTimeTumbleWindow.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testProcTimeTumbleWindow.out
index d9c1ed0..bc5fd3f 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testProcTimeTumbleWindow.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/GroupWindowAggregateJsonPlanTest_jsonplan/testProcTimeTumbleWindow.out
@@ -266,6 +266,11 @@
}, {
"id" : 6,
"type" : "stream-exec-group-window-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1",
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$2",
@@ -407,6 +412,12 @@
}, {
"id" : 8,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IncrementalAggregateJsonPlanTest_jsonplan/testIncrementalAggregate.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IncrementalAggregateJsonPlanTest_jsonplan/testIncrementalAggregate.out
index 76cc64f..a2bcf70 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IncrementalAggregateJsonPlanTest_jsonplan/testIncrementalAggregate.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IncrementalAggregateJsonPlanTest_jsonplan/testIncrementalAggregate.out
@@ -102,6 +102,10 @@
}, {
"id" : 4,
"type" : "stream-exec-local-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "true",
+ "table.exec.mini-batch.size" : "5"
+ },
"grouping" : [ 0, 2 ],
"aggCalls" : [ {
"name" : null,
@@ -209,6 +213,10 @@
}, {
"id" : 6,
"type" : "stream-exec-incremental-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "true",
+ "table.exec.mini-batch.size" : "5"
+ },
"partialAggGrouping" : [ 0, 1 ],
"finalAggGrouping" : [ 0 ],
"partialOriginalAggCalls" : [ {
@@ -250,6 +258,10 @@
}, {
"id" : 8,
"type" : "stream-exec-global-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "true",
+ "table.exec.mini-batch.size" : "5"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : null,
@@ -277,6 +289,12 @@
}, {
"id" : 9,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IncrementalAggregateJsonPlanTest_jsonplan/testIncrementalAggregateWithSumCountDistinctAndRetraction.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IncrementalAggregateJsonPlanTest_jsonplan/testIncrementalAggregateWithSumCountDistinctAndRetraction.out
index abb17ca..c4a0f21 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IncrementalAggregateJsonPlanTest_jsonplan/testIncrementalAggregateWithSumCountDistinctAndRetraction.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IncrementalAggregateJsonPlanTest_jsonplan/testIncrementalAggregateWithSumCountDistinctAndRetraction.out
@@ -62,6 +62,10 @@
}, {
"id" : 3,
"type" : "stream-exec-local-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "true",
+ "table.exec.mini-batch.size" : "5"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "b",
@@ -110,6 +114,10 @@
}, {
"id" : 5,
"type" : "stream-exec-global-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "true",
+ "table.exec.mini-batch.size" : "5"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "b",
@@ -187,6 +195,10 @@
}, {
"id" : 7,
"type" : "stream-exec-local-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "true",
+ "table.exec.mini-batch.size" : "5"
+ },
"grouping" : [ 0, 2 ],
"aggCalls" : [ {
"name" : null,
@@ -315,6 +327,10 @@
}, {
"id" : 9,
"type" : "stream-exec-incremental-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "true",
+ "table.exec.mini-batch.size" : "5"
+ },
"partialAggGrouping" : [ 0, 1 ],
"finalAggGrouping" : [ 0 ],
"partialOriginalAggCalls" : [ {
@@ -375,6 +391,10 @@
}, {
"id" : 11,
"type" : "stream-exec-global-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "true",
+ "table.exec.mini-batch.size" : "5"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : null,
@@ -421,6 +441,12 @@
}, {
"id" : 12,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinJsonPlanTest_jsonplan/testProcessingTimeInnerJoinWithOnClause.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinJsonPlanTest_jsonplan/testProcessingTimeInnerJoinWithOnClause.out
index 05bdf0d..4d61ded 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinJsonPlanTest_jsonplan/testProcessingTimeInnerJoinWithOnClause.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinJsonPlanTest_jsonplan/testProcessingTimeInnerJoinWithOnClause.out
@@ -656,6 +656,12 @@
}, {
"id" : 13,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinJsonPlanTest_jsonplan/testRowTimeInnerJoinWithOnClause.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinJsonPlanTest_jsonplan/testRowTimeInnerJoinWithOnClause.out
index d20fb04..94927bb 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinJsonPlanTest_jsonplan/testRowTimeInnerJoinWithOnClause.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/IntervalJoinJsonPlanTest_jsonplan/testRowTimeInnerJoinWithOnClause.out
@@ -480,6 +480,12 @@
}, {
"id" : 11,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testInnerJoin.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testInnerJoin.out
index fae9d80..0355fb0 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testInnerJoin.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testInnerJoin.out
@@ -136,6 +136,12 @@
}, {
"id" : 6,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testInnerJoinWithEqualPk.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testInnerJoinWithEqualPk.out
index a75de5c..5d80fb2 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testInnerJoinWithEqualPk.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testInnerJoinWithEqualPk.out
@@ -56,6 +56,10 @@
}, {
"id" : 3,
"type" : "stream-exec-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ ],
"aggCallNeedRetractions" : [ ],
@@ -139,6 +143,10 @@
}, {
"id" : 7,
"type" : "stream-exec-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ ],
"aggCallNeedRetractions" : [ ],
@@ -196,6 +204,12 @@
}, {
"id" : 10,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testInnerJoinWithPk.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testInnerJoinWithPk.out
index 3bd9221..149408c 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testInnerJoinWithPk.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testInnerJoinWithPk.out
@@ -56,6 +56,10 @@
}, {
"id" : 3,
"type" : "stream-exec-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "a2",
@@ -170,6 +174,10 @@
}, {
"id" : 8,
"type" : "stream-exec-group-aggregate_1",
+ "configuration" : {
+ "table.exec.mini-batch.enabled" : "false",
+ "table.exec.mini-batch.size" : "-1"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "b2",
@@ -288,6 +296,12 @@
}, {
"id" : 13,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testLeftJoinNonEqui.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testLeftJoinNonEqui.out
index 289eb09..27df7d8 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testLeftJoinNonEqui.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/JoinJsonPlanTest_jsonplan/testLeftJoinNonEqui.out
@@ -172,6 +172,12 @@
}, {
"id" : 7,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LimitJsonPlanTest_jsonplan/testLimit.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LimitJsonPlanTest_jsonplan/testLimit.out
index aa1c8c2..361b644 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LimitJsonPlanTest_jsonplan/testLimit.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LimitJsonPlanTest_jsonplan/testLimit.out
@@ -61,6 +61,9 @@
}, {
"id" : 3,
"type" : "stream-exec-limit_1",
+ "configuration" : {
+ "table.exec.rank.topn-cache-size" : "10000"
+ },
"rankRange" : {
"type" : "Constant",
"start" : 1,
@@ -112,6 +115,12 @@
}, {
"id" : 5,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTable.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTable.out
index 4f4afab..cba8ae4 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTable.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTable.out
@@ -378,6 +378,12 @@
}, {
"id" : 6,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTableWithProjectionPushDown.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTableWithProjectionPushDown.out
index 17946ab..c3012c7 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTableWithProjectionPushDown.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTableWithProjectionPushDown.out
@@ -368,6 +368,12 @@
}, {
"id" : 6,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/MatchRecognizeJsonPlanTest_jsonplan/testMatch.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/MatchRecognizeJsonPlanTest_jsonplan/testMatch.out
index b921155..c7bbd66 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/MatchRecognizeJsonPlanTest_jsonplan/testMatch.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/MatchRecognizeJsonPlanTest_jsonplan/testMatch.out
@@ -302,6 +302,12 @@
}, {
"id" : 5,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeBoundedNonPartitionedRangeOver.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeBoundedNonPartitionedRangeOver.out
index 2541c41..4a91e46 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeBoundedNonPartitionedRangeOver.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeBoundedNonPartitionedRangeOver.out
@@ -362,6 +362,12 @@
}, {
"id" : 8,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeBoundedPartitionedRangeOver.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeBoundedPartitionedRangeOver.out
index 461837d..15f5426 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeBoundedPartitionedRangeOver.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeBoundedPartitionedRangeOver.out
@@ -422,6 +422,12 @@
}, {
"id" : 8,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeBoundedPartitionedRowsOverWithBuiltinProctime.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeBoundedPartitionedRowsOverWithBuiltinProctime.out
index fba1d48..5d722f4 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeBoundedPartitionedRowsOverWithBuiltinProctime.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeBoundedPartitionedRowsOverWithBuiltinProctime.out
@@ -359,6 +359,12 @@
}, {
"id" : 7,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeUnboundedPartitionedRangeOver.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeUnboundedPartitionedRangeOver.out
index 6f7c396..c4a2946 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeUnboundedPartitionedRangeOver.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProcTimeUnboundedPartitionedRangeOver.out
@@ -393,6 +393,12 @@
}, {
"id" : 8,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProctimeBoundedDistinctPartitionedRowOver.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProctimeBoundedDistinctPartitionedRowOver.out
index 6c8d61c..4eaf0b6 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProctimeBoundedDistinctPartitionedRowOver.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProctimeBoundedDistinctPartitionedRowOver.out
@@ -403,6 +403,12 @@
}, {
"id" : 8,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProctimeBoundedDistinctWithNonDistinctPartitionedRowOver.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProctimeBoundedDistinctWithNonDistinctPartitionedRowOver.out
index 3e8b12d..b7477b9 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProctimeBoundedDistinctWithNonDistinctPartitionedRowOver.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testProctimeBoundedDistinctWithNonDistinctPartitionedRowOver.out
@@ -493,6 +493,12 @@
}, {
"id" : 8,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testRowTimeBoundedPartitionedRowsOver.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testRowTimeBoundedPartitionedRowsOver.out
index cd7d26f..9eb9209 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testRowTimeBoundedPartitionedRowsOver.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/OverAggregateJsonPlanTest_jsonplan/testRowTimeBoundedPartitionedRowsOver.out
@@ -237,6 +237,12 @@
}, {
"id" : 6,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/RankJsonPlanTest_jsonplan/testRank.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/RankJsonPlanTest_jsonplan/testRank.out
index 5a3a6e6..3c0fde4 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/RankJsonPlanTest_jsonplan/testRank.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/RankJsonPlanTest_jsonplan/testRank.out
@@ -72,6 +72,9 @@
}, {
"id" : 4,
"type" : "stream-exec-rank_1",
+ "configuration" : {
+ "table.exec.rank.topn-cache-size" : "10000"
+ },
"rankType" : "ROW_NUMBER",
"partition" : {
"fields" : [ 1 ]
@@ -126,6 +129,12 @@
}, {
"id" : 6,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/SortLimitJsonPlanTest_jsonplan/testSortLimit.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/SortLimitJsonPlanTest_jsonplan/testSortLimit.out
index 6ba5bf6..c0a3251 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/SortLimitJsonPlanTest_jsonplan/testSortLimit.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/SortLimitJsonPlanTest_jsonplan/testSortLimit.out
@@ -58,6 +58,9 @@
}, {
"id" : 3,
"type" : "stream-exec-sort-limit_1",
+ "configuration" : {
+ "table.exec.rank.topn-cache-size" : "10000"
+ },
"orderBy" : {
"fields" : [ {
"index" : 1,
@@ -113,6 +116,12 @@
}, {
"id" : 5,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSinkJsonPlanTest_jsonplan/testOverwrite.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSinkJsonPlanTest_jsonplan/testOverwrite.out
index 4dc91d9..c9d3d04 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSinkJsonPlanTest_jsonplan/testOverwrite.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSinkJsonPlanTest_jsonplan/testOverwrite.out
@@ -34,6 +34,12 @@
}, {
"id" : 2,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSinkJsonPlanTest_jsonplan/testPartitioning.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSinkJsonPlanTest_jsonplan/testPartitioning.out
index 4318664..4858fb9 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSinkJsonPlanTest_jsonplan/testPartitioning.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSinkJsonPlanTest_jsonplan/testPartitioning.out
@@ -69,6 +69,12 @@
}, {
"id" : 3,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSinkJsonPlanTest_jsonplan/testWritingMetadata.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSinkJsonPlanTest_jsonplan/testWritingMetadata.out
index 00f9f79..60411d8 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSinkJsonPlanTest_jsonplan/testWritingMetadata.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSinkJsonPlanTest_jsonplan/testWritingMetadata.out
@@ -34,6 +34,12 @@
}, {
"id" : 2,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testFilterPushDown.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testFilterPushDown.out
index 0c8aa8b0..eed66e5 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testFilterPushDown.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testFilterPushDown.out
@@ -53,6 +53,12 @@
}, {
"id" : 2,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testLimitPushDown.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testLimitPushDown.out
index 55037d9..50c566d 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testLimitPushDown.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testLimitPushDown.out
@@ -50,6 +50,9 @@
}, {
"id" : 3,
"type" : "stream-exec-limit_1",
+ "configuration" : {
+ "table.exec.rank.topn-cache-size" : "10000"
+ },
"rankRange" : {
"type" : "Constant",
"start" : 1,
@@ -79,6 +82,12 @@
}, {
"id" : 4,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testPartitionPushDown.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testPartitionPushDown.out
index 772fffb..9232850 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testPartitionPushDown.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testPartitionPushDown.out
@@ -81,6 +81,12 @@
}, {
"id" : 3,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testProjectPushDown.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testProjectPushDown.out
index 9de3380..98a2518 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testProjectPushDown.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testProjectPushDown.out
@@ -43,6 +43,12 @@
}, {
"id" : 2,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`sink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testReadingMetadata.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testReadingMetadata.out
index 265707e..a8014cf 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testReadingMetadata.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testReadingMetadata.out
@@ -49,6 +49,12 @@
}, {
"id" : 2,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`sink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testWatermarkPushDown.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testWatermarkPushDown.out
index f8798e3..bf02aa5 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testWatermarkPushDown.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSourceJsonPlanTest_jsonplan/testWatermarkPushDown.out
@@ -113,6 +113,12 @@
}, {
"id" : 2,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`sink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalJoinJsonPlanTest_jsonplan/testJoinTemporalFunction.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalJoinJsonPlanTest_jsonplan/testJoinTemporalFunction.out
index 7c4fd06..6c09307 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalJoinJsonPlanTest_jsonplan/testJoinTemporalFunction.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalJoinJsonPlanTest_jsonplan/testJoinTemporalFunction.out
@@ -324,6 +324,12 @@
}, {
"id" : 9,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalJoinJsonPlanTest_jsonplan/testTemporalTableJoin.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalJoinJsonPlanTest_jsonplan/testTemporalTableJoin.out
index 2bf4564..7666686 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalJoinJsonPlanTest_jsonplan/testTemporalTableJoin.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalJoinJsonPlanTest_jsonplan/testTemporalTableJoin.out
@@ -324,6 +324,12 @@
}, {
"id" : 9,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalSortJsonPlanTest_jsonplan/testSortProcessingTime.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalSortJsonPlanTest_jsonplan/testSortProcessingTime.out
index 6386343..a8b9d4c 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalSortJsonPlanTest_jsonplan/testSortProcessingTime.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalSortJsonPlanTest_jsonplan/testSortProcessingTime.out
@@ -309,6 +309,12 @@
}, {
"id" : 7,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalSortJsonPlanTest_jsonplan/testSortRowTime.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalSortJsonPlanTest_jsonplan/testSortRowTime.out
index 1c5ffe1..1bfbf4d 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalSortJsonPlanTest_jsonplan/testSortRowTime.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalSortJsonPlanTest_jsonplan/testSortRowTime.out
@@ -255,6 +255,12 @@
}, {
"id" : 7,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/UnionJsonPlanTest_jsonplan/testUnion.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/UnionJsonPlanTest_jsonplan/testUnion.out
index 1e050955..246a01a 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/UnionJsonPlanTest_jsonplan/testUnion.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/UnionJsonPlanTest_jsonplan/testUnion.out
@@ -92,6 +92,12 @@
}, {
"id" : 4,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ValuesJsonPlanTest_jsonplan/testValues.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ValuesJsonPlanTest_jsonplan/testValues.out
index a1a7ff0..fd83244 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ValuesJsonPlanTest_jsonplan/testValues.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ValuesJsonPlanTest_jsonplan/testValues.out
@@ -78,6 +78,12 @@
}, {
"id" : 3,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WatermarkAssignerJsonPlanTest_jsonplan/testWatermarkAssigner.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WatermarkAssignerJsonPlanTest_jsonplan/testWatermarkAssigner.out
index 15b2bb8..4ebd7dd 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WatermarkAssignerJsonPlanTest_jsonplan/testWatermarkAssigner.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WatermarkAssignerJsonPlanTest_jsonplan/testWatermarkAssigner.out
@@ -104,6 +104,12 @@
}, {
"id" : 3,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`sink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testDistinctSplitEnabled.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testDistinctSplitEnabled.out
index be85b4c..94423a7 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testDistinctSplitEnabled.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testDistinctSplitEnabled.out
@@ -242,6 +242,9 @@
}, {
"id" : 5,
"type" : "stream-exec-local-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0, 3 ],
"aggCalls" : [ {
"name" : null,
@@ -399,6 +402,9 @@
}, {
"id" : 7,
"type" : "stream-exec-global-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0, 1 ],
"aggCalls" : [ {
"name" : null,
@@ -549,6 +555,9 @@
}, {
"id" : 9,
"type" : "stream-exec-local-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : null,
@@ -619,6 +628,9 @@
}, {
"id" : 11,
"type" : "stream-exec-global-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : null,
@@ -772,6 +784,12 @@
}, {
"id" : 13,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindow.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindow.out
index 4d3c3dc..cdfeaf5 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindow.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindow.out
@@ -221,6 +221,9 @@
}, {
"id" : 5,
"type" : "stream-exec-local-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$2",
@@ -282,6 +285,9 @@
}, {
"id" : 7,
"type" : "stream-exec-global-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$2",
@@ -407,6 +413,12 @@
}, {
"id" : 9,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindowWithOffset.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindowWithOffset.out
index 3915c80..aa59906 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindowWithOffset.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeCumulateWindowWithOffset.out
@@ -221,6 +221,9 @@
}, {
"id" : 5,
"type" : "stream-exec-local-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$2",
@@ -283,6 +286,9 @@
}, {
"id" : 7,
"type" : "stream-exec-global-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$2",
@@ -409,6 +415,12 @@
}, {
"id" : 9,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindow.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindow.out
index 4c8d84a..74a7803 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindow.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindow.out
@@ -221,6 +221,9 @@
}, {
"id" : 5,
"type" : "stream-exec-local-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$1",
@@ -282,6 +285,9 @@
}, {
"id" : 7,
"type" : "stream-exec-global-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$1",
@@ -403,6 +409,12 @@
}, {
"id" : 9,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindowWithOffset.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindowWithOffset.out
index 25d8c8f..fd02b9e 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindowWithOffset.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindowWithOffset.out
@@ -221,6 +221,9 @@
}, {
"id" : 5,
"type" : "stream-exec-local-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$1",
@@ -283,6 +286,9 @@
}, {
"id" : 7,
"type" : "stream-exec-global-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$1",
@@ -405,6 +411,12 @@
}, {
"id" : 9,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out
index 6e258b3..9d90642 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out
@@ -221,6 +221,9 @@
}, {
"id" : 5,
"type" : "stream-exec-local-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$3",
@@ -463,6 +466,9 @@
}, {
"id" : 7,
"type" : "stream-exec-global-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$3",
@@ -619,6 +625,12 @@
}, {
"id" : 9,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindowWithOffset.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindowWithOffset.out
index ea0bd37..577951a 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindowWithOffset.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testEventTimeTumbleWindowWithOffset.out
@@ -221,6 +221,9 @@
}, {
"id" : 5,
"type" : "stream-exec-local-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$3",
@@ -464,6 +467,9 @@
}, {
"id" : 7,
"type" : "stream-exec-global-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$3",
@@ -621,6 +627,12 @@
}, {
"id" : 9,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeCumulateWindow.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeCumulateWindow.out
index 0217355..b7c7cb2 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeCumulateWindow.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeCumulateWindow.out
@@ -286,6 +286,9 @@
}, {
"id" : 6,
"type" : "stream-exec-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$1",
@@ -377,6 +380,12 @@
}, {
"id" : 8,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeHopWindow.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeHopWindow.out
index 2973abc..0f5cbd6 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeHopWindow.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeHopWindow.out
@@ -287,6 +287,9 @@
}, {
"id" : 6,
"type" : "stream-exec-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$1",
@@ -377,6 +380,12 @@
}, {
"id" : 8,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeTumbleWindow.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeTumbleWindow.out
index 02faef6..2b2369f 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeTumbleWindow.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowAggregateJsonPlanTest_jsonplan/testProcTimeTumbleWindow.out
@@ -266,6 +266,9 @@
}, {
"id" : 6,
"type" : "stream-exec-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "EXPR$2",
@@ -360,6 +363,12 @@
}, {
"id" : 8,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowJoinJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowJoinJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out
index 617e8b8..2a59a3f 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowJoinJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowJoinJsonPlanTest_jsonplan/testEventTimeTumbleWindow.out
@@ -170,6 +170,9 @@
}, {
"id" : 4,
"type" : "stream-exec-local-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "cnt",
@@ -305,6 +308,9 @@
}, {
"id" : 6,
"type" : "stream-exec-global-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "cnt",
@@ -650,6 +656,9 @@
}, {
"id" : 12,
"type" : "stream-exec-local-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "cnt",
@@ -785,6 +794,9 @@
}, {
"id" : 14,
"type" : "stream-exec-global-window-aggregate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"grouping" : [ 0 ],
"aggCalls" : [ {
"name" : "cnt",
@@ -963,6 +975,9 @@
}, {
"id" : 17,
"type" : "stream-exec-window-join_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"joinSpec" : {
"joinType" : "INNER",
"leftKeys" : [ 0 ],
@@ -1064,6 +1079,12 @@
}, {
"id" : 19,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testFollowedByWindowDeduplicate.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testFollowedByWindowDeduplicate.out
index ea72435..a10937b 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testFollowedByWindowDeduplicate.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testFollowedByWindowDeduplicate.out
@@ -209,6 +209,9 @@
}, {
"id" : 4,
"type" : "stream-exec-window-table-function_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"windowing" : {
"strategy" : "TimeAttribute",
"window" : {
@@ -381,6 +384,9 @@
}, {
"id" : 7,
"type" : "stream-exec-window-deduplicate_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"partitionKeys" : [ 0 ],
"orderKey" : 3,
"keepLastRow" : true,
@@ -470,6 +476,12 @@
}, {
"id" : 9,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testFollowedByWindowJoin.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testFollowedByWindowJoin.out
index c988616..df66bb0 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testFollowedByWindowJoin.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testFollowedByWindowJoin.out
@@ -168,6 +168,9 @@
}, {
"id" : 4,
"type" : "stream-exec-window-table-function_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"windowing" : {
"strategy" : "TimeAttribute",
"window" : {
@@ -453,6 +456,9 @@
}, {
"id" : 10,
"type" : "stream-exec-window-table-function_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"windowing" : {
"strategy" : "TimeAttribute",
"window" : {
@@ -573,6 +579,9 @@
}, {
"id" : 13,
"type" : "stream-exec-window-join_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"joinSpec" : {
"joinType" : "INNER",
"leftKeys" : [ 2 ],
@@ -674,6 +683,12 @@
}, {
"id" : 15,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testFollowedByWindowRank.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testFollowedByWindowRank.out
index 5242939..398af03 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testFollowedByWindowRank.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testFollowedByWindowRank.out
@@ -209,6 +209,9 @@
}, {
"id" : 4,
"type" : "stream-exec-window-table-function_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"windowing" : {
"strategy" : "TimeAttribute",
"window" : {
@@ -323,6 +326,9 @@
}, {
"id" : 7,
"type" : "stream-exec-window-rank_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"rankType" : "ROW_NUMBER",
"partitionSpec" : {
"fields" : [ 0 ]
@@ -401,6 +407,12 @@
}, {
"id" : 9,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testIndividualWindowTVF.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testIndividualWindowTVF.out
index aea8c50..2443023 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testIndividualWindowTVF.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testIndividualWindowTVF.out
@@ -168,6 +168,9 @@
}, {
"id" : 4,
"type" : "stream-exec-window-table-function_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"windowing" : {
"strategy" : "TimeAttribute",
"window" : {
@@ -261,6 +264,12 @@
}, {
"id" : 6,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",
diff --git a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testIndividualWindowTVFProcessingTime.out b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testIndividualWindowTVFProcessingTime.out
index e3af3a1..f3a3218 100644
--- a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testIndividualWindowTVFProcessingTime.out
+++ b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/WindowTableFunctionJsonPlanTest_jsonplan/testIndividualWindowTVFProcessingTime.out
@@ -264,6 +264,9 @@
}, {
"id" : 5,
"type" : "stream-exec-window-table-function_1",
+ "configuration" : {
+ "table.local-time-zone" : "default"
+ },
"windowing" : {
"strategy" : "TimeAttribute",
"window" : {
@@ -359,6 +362,12 @@
}, {
"id" : 7,
"type" : "stream-exec-sink_1",
+ "configuration" : {
+ "table.exec.sink.keyed-shuffle" : "AUTO",
+ "table.exec.sink.not-null-enforcer" : "ERROR",
+ "table.exec.sink.type-length-enforcer" : "IGNORE",
+ "table.exec.sink.upsert-materialize" : "AUTO"
+ },
"dynamicTableSink" : {
"table" : {
"identifier" : "`default_catalog`.`default_database`.`MySink`",