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 0b0a76a [FLINK-25369][table] Provide tables of specified
catalog/database
add e4a3272 [hotfix][table-api-java] Make DataTypeFactory configurable
for CatalogManager
add 6296f6b [hotfix][table-common] Check for invalid unresolved types in
DataTypes.of(LogicalType)
add d7f5c51 [hotfix][table-common] Create UnresolvedIdentifier from
ObjectIdentifier
add 3d19ea5 [hotfix][table-api-java] Expose LogicalType creation in
DataTypeFactory
add 39d3b84 [hotfix][table-common] Fix LogicalType to DataType conversion
for DistinctType
add f28ba66 [hotfix][table-common] Allow disabling autoboxing for
DataTypeUtils.isInternal
add 6ed132b [hotfix][table-planner] Make JSON plan test base more lenient
for differently configured IDEs
add 65a4657 [FLINK-25230][table-planner] Harden type serialization for
LogicalType and DataType
add 562344b [FLINK-25230][table-planner] Regenerate JSON plans
No new revisions were added by this update.
Summary of changes:
.../apache/flink/table/catalog/CatalogManager.java | 11 +-
.../flink/table/catalog/DataTypeFactoryImpl.java | 28 +-
.../java/org/apache/flink/table/api/DataTypes.java | 2 +-
.../flink/table/catalog/DataTypeFactory.java | 25 +-
.../flink/table/catalog/UnresolvedIdentifier.java | 9 +
.../apache/flink/table/types/FieldsDataType.java | 2 +-
.../table/types/extraction/ExtractionUtils.java | 27 +
.../flink/table/types/utils/DataTypeUtils.java | 13 +-
.../types/utils/LogicalTypeDataTypeConverter.java | 36 +-
.../table/types/utils/DataTypeFactoryMock.java | 17 +-
.../nodes/exec/serde/DataTypeJsonDeserializer.java | 190 ++++++
.../nodes/exec/serde/DataTypeJsonSerializer.java | 171 +++++
.../exec/serde/ExecNodeGraphJsonPlanGenerator.java | 16 +-
.../plan/nodes/exec/serde/JsonSerdeUtil.java | 13 +-
.../exec/serde/LogicalTypeJsonDeserializer.java | 555 ++++++++--------
.../exec/serde/LogicalTypeJsonSerializer.java | 723 ++++++++++++---------
.../exec/serde/LogicalWindowJsonDeserializer.java | 6 +-
.../exec/serde/LogicalWindowJsonSerializer.java | 24 +-
.../exec/serde/RelDataTypeJsonSerializer.java | 19 +-
.../plan/nodes/exec/serde/SerdeContext.java | 14 +-
...r.java => WindowReferenceJsonDeserializer.java} | 46 +-
...zer.java => WindowReferenceJsonSerializer.java} | 32 +-
.../table/planner/typeutils/DataViewUtils.java | 52 +-
.../nodes/exec/serde/DataTypeJsonSerdeTest.java | 127 ++++
.../exec/serde/DynamicTableSinkSpecSerdeTest.java | 8 +-
.../serde/DynamicTableSourceSpecSerdeTest.java | 8 +-
...erdeTest.java => LogicalTypeJsonSerdeTest.java} | 296 ++++++---
.../exec/serde/LogicalTypeSerdeCoverageTest.java | 60 --
.../nodes/exec/serde/LogicalWindowSerdeTest.java | 3 +-
...erdeTest.java => RelDataTypeJsonSerdeTest.java} | 15 +-
.../test/resources/jsonplan/testGetJsonPlan.out | 34 +-
.../CalcJsonPlanTest_jsonplan/testComplexCalc.out | 69 +-
.../CalcJsonPlanTest_jsonplan/testSimpleFilter.out | 57 +-
.../testSimpleProject.out | 40 +-
.../testChangelogSource.out | 70 +-
.../testUpsertSource.out | 60 +-
.../testCrossJoin.out | 60 +-
.../testCrossJoinOverrideParameters.out | 60 +-
.../testJoinWithFilter.out | 60 +-
.../testLeftOuterJoinWithLiteralTrue.out | 60 +-
.../testDeduplication.out | 120 +---
.../ExpandJsonPlanTest_jsonplan/testExpand.out | 142 +---
...tDistinctAggCalls[isMiniBatchEnabled=false].out | 106 +--
...stDistinctAggCalls[isMiniBatchEnabled=true].out | 332 ++++------
...gCallsWithGroupBy[isMiniBatchEnabled=false].out | 106 +--
...ggCallsWithGroupBy[isMiniBatchEnabled=true].out | 146 +----
...AggWithoutGroupBy[isMiniBatchEnabled=false].out | 110 +---
...eAggWithoutGroupBy[isMiniBatchEnabled=true].out | 154 +----
...erDefinedAggCalls[isMiniBatchEnabled=false].out | 98 +--
...serDefinedAggCalls[isMiniBatchEnabled=true].out | 112 +---
.../testEventTimeHopWindow.out | 85 +--
.../testEventTimeSessionWindow.out | 85 +--
.../testEventTimeTumbleWindow.out | 165 ++---
.../testProcTimeHopWindow.out | 90 +--
.../testProcTimeSessionWindow.out | 90 +--
.../testProcTimeTumbleWindow.out | 131 +---
.../testIncrementalAggregate.out | 190 ++----
...lAggregateWithSumCountDistinctAndRetraction.out | 278 +++-----
.../testProcessingTimeInnerJoinWithOnClause.out | 176 ++---
.../testRowTimeInnerJoinWithOnClause.out | 150 ++---
.../JoinJsonPlanTest_jsonplan/testInnerJoin.out | 84 +--
.../testInnerJoinWithEqualPk.out | 132 +---
.../testInnerJoinWithPk.out | 182 +-----
.../testLeftJoinNonEqui.out | 114 +---
.../LimitJsonPlanTest_jsonplan/testLimit.out | 60 +-
.../testJoinTemporalTable.out | 140 ++--
...testJoinTemporalTableWithProjectionPushDown.out | 126 +---
.../testMatch.out | 54 +-
.../testProcTimeBoundedNonPartitionedRangeOver.out | 136 ++--
.../testProcTimeBoundedPartitionedRangeOver.out | 148 ++---
...undedPartitionedRowsOverWithBuiltinProctime.out | 134 ++--
.../testProcTimeUnboundedPartitionedRangeOver.out | 143 ++--
...stProctimeBoundedDistinctPartitionedRowOver.out | 143 ++--
...edDistinctWithNonDistinctPartitionedRowOver.out | 143 ++--
.../testRowTimeBoundedPartitionedRowsOver.out | 107 +--
.../testPythonCalc.out | 50 +-
.../testPythonFunctionInWhereClause.out | 74 +--
.../testJoinWithFilter.out | 85 +--
.../testPythonTableFunction.out | 85 +--
.../tesPythonAggCallsWithGroupBy.out | 94 +--
.../testEventTimeHopWindow.out | 90 +--
.../testEventTimeSessionWindow.out | 90 +--
.../testEventTimeTumbleWindow.out | 153 ++---
.../testProcTimeHopWindow.out | 96 ++-
.../testProcTimeSessionWindow.out | 96 ++-
.../testProcTimeTumbleWindow.out | 137 ++--
.../testProcTimeBoundedNonPartitionedRangeOver.out | 136 ++--
.../testProcTimeBoundedPartitionedRangeOver.out | 145 ++---
...undedPartitionedRowsOverWithBuiltinProctime.out | 124 ++--
.../testProcTimeUnboundedPartitionedRangeOver.out | 145 ++---
.../testRowTimeBoundedPartitionedRowsOver.out | 127 ++--
.../stream/RankJsonPlanTest_jsonplan/testRank.out | 71 +-
.../testSortLimit.out | 70 +-
.../testOverwrite.out | 24 +-
.../testPartitioning.out | 54 +-
.../testWritingMetadata.out | 36 +-
.../testFilterPushDown.out | 24 +-
.../testLimitPushDown.out | 48 +-
.../testPartitionPushDown.out | 54 +-
.../testProjectPushDown.out | 40 +-
.../testReadingMetadata.out | 46 +-
.../testWatermarkPushDown.out | 32 +-
.../testJoinTemporalFunction.out | 115 ++--
.../testTemporalTableJoin.out | 115 ++--
.../testSortProcessingTime.out | 106 ++-
.../testSortRowTime.out | 96 +--
.../UnionJsonPlanTest_jsonplan/testUnion.out | 60 +-
.../ValuesJsonPlanTest_jsonplan/testValues.out | 36 +-
.../testWatermarkAssigner.out | 39 +-
.../testDistinctSplitEnabled.out | 385 +++--------
.../testEventTimeCumulateWindow.out | 169 +----
.../testEventTimeCumulateWindowWithOffset.out | 169 +----
.../testEventTimeHopWindow.out | 159 +----
.../testEventTimeHopWindowWithOffset.out | 159 +----
.../testEventTimeTumbleWindow.out | 379 +++++------
.../testEventTimeTumbleWindowWithOffset.out | 379 +++++------
.../testProcTimeCumulateWindow.out | 126 +---
.../testProcTimeHopWindow.out | 114 +---
.../testProcTimeTumbleWindow.out | 128 +---
.../testEventTimeTumbleWindow.out | 582 +++++------------
.../testFollowedByWindowDeduplicate.out | 230 +++----
.../testFollowedByWindowJoin.out | 374 ++---------
.../testFollowedByWindowRank.out | 218 ++-----
.../testIndividualWindowTVF.out | 131 +---
.../testIndividualWindowTVFProcessingTime.out | 147 ++---
.../flink/table/planner/utils/TableTestBase.scala | 18 +-
.../table/runtime/groupwindow/WindowReference.java | 16 +-
127 files changed, 4537 insertions(+), 9969 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/DataTypeJsonDeserializer.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/DataTypeJsonSerializer.java
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/{ObjectIdentifierJsonDeserializer.java
=> WindowReferenceJsonDeserializer.java} (54%)
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/{ObjectIdentifierJsonSerializer.java
=> WindowReferenceJsonSerializer.java} (63%)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/DataTypeJsonSerdeTest.java
rename
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/{LogicalTypeSerdeTest.java
=> LogicalTypeJsonSerdeTest.java} (56%)
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/LogicalTypeSerdeCoverageTest.java
rename
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/{RelDataTypeSerdeTest.java
=> RelDataTypeJsonSerdeTest.java} (97%)
