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 6518d20 [FLINK-21558][coordination] Skip check if slotreport
indicates no change
add 01d7095 [FLINK-21396][table-planner-blink] Use ResolvedCatalogTable
within the planner
No new revisions were added by this update.
Summary of changes:
.../ElasticsearchUpsertTableSinkFactoryBase.java | 4 ++
.../flink/connector/hbase1/HBase1TableFactory.java | 4 ++
.../flink/connector/hbase2/HBase2TableFactory.java | 4 ++
.../jdbc/table/JdbcTableSourceSinkFactory.java | 4 ++
.../kafka/KafkaTableSourceSinkFactoryBase.java | 4 ++
.../gateway/utils/TestTableSinkFactoryBase.java | 3 +
.../gateway/utils/TestTableSourceFactoryBase.java | 3 +
.../flink/table/sinks/CsvTableSinkFactoryBase.java | 3 +
.../table/sources/CsvTableSourceFactoryBase.java | 3 +
.../apache/flink/table/catalog/CatalogManager.java | 3 +-
.../expressions/resolver/ExpressionResolver.java | 9 ++-
.../flink/table/catalog/SchemaResolutionTest.java | 7 +-
.../flink/table/utils/CatalogManagerMocks.java | 4 +-
.../flink/table/utils/TableSourceFactoryMock.java | 3 +
.../flink/table/catalog/CatalogPropertiesUtil.java | 5 +-
.../flink/table/catalog/ResolvedCatalogTable.java | 2 +-
.../apache/flink/table/catalog/ResolvedSchema.java | 20 ++++--
.../table/descriptors/DescriptorProperties.java | 2 +
.../flink/table/types/utils/DataTypeUtils.java | 15 +++++
.../table/planner/catalog/CatalogSchemaTable.java | 5 +-
.../planner/plan/FlinkCalciteCatalogReader.java | 33 ++++++----
.../exec/serde/CatalogTableJsonDeserializer.java | 29 ++++++---
.../exec/serde/CatalogTableJsonSerializer.java | 21 +++---
.../plan/nodes/exec/spec/CatalogTableSpecBase.java | 9 +--
.../plan/nodes/exec/spec/DynamicTableSinkSpec.java | 4 +-
.../nodes/exec/spec/DynamicTableSourceSpec.java | 10 ++-
.../PushProjectIntoTableSourceScanRule.java | 10 +--
.../planner/plan/schema/CatalogSourceTable.java | 75 ++++++++++------------
.../table/planner/sinks/DynamicSinkUtils.java | 5 +-
.../table/planner/sources/DynamicSourceUtils.java | 46 +++++++------
.../table/planner/delegation/PlannerBase.scala | 38 ++++++-----
.../planner/plan/nodes/calcite/LogicalSink.scala | 6 +-
.../table/planner/plan/nodes/calcite/Sink.scala | 6 +-
.../plan/nodes/logical/FlinkLogicalSink.scala | 6 +-
.../nodes/physical/batch/BatchPhysicalSink.scala | 4 +-
.../nodes/physical/stream/StreamPhysicalSink.scala | 4 +-
.../physical/batch/BatchPhysicalSinkRule.scala | 2 +-
.../planner/plan/schema/TableSourceTable.scala | 6 +-
.../exec/serde/DynamicTableSinkSpecSerdeTest.java | 55 +++++++++++++---
.../serde/DynamicTableSourceSpecSerdeTest.java | 44 +++++++++++--
.../testProcTimeCumulateWindow.out | 2 +-
.../testProcTimeHopWindow.out | 2 +-
.../planner/plan/metadata/MetadataTestUtil.scala | 20 ++++--
.../flink/table/utils/InMemoryTableFactory.scala | 2 +
44 files changed, 368 insertions(+), 178 deletions(-)
