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 55a1d1b [FLINK-21348] Add tests for AdaptiveScheduler's
StateWithExecutionGraph
add 73338e2 [FLINK-21913][table][connectors] Update
DynamicTableFactory.Context to use ResolvedCatalogTable
No new revisions were added by this update.
Summary of changes:
.../elasticsearch/table/TestContext.java | 59 ++++----
.../Elasticsearch6DynamicSinkFactoryTest.java | 87 ++++++------
.../table/Elasticsearch6DynamicSinkITCase.java | 29 ++--
.../Elasticsearch7DynamicSinkFactoryTest.java | 92 +++++++------
.../table/Elasticsearch7DynamicSinkITCase.java | 30 ++--
.../hbase1/HBaseDynamicTableFactoryTest.java | 109 ++++++---------
.../hbase2/HBaseDynamicTableFactoryTest.java | 118 ++++++----------
.../connectors/hive/HiveDynamicTableFactory.java | 3 +-
.../hive/HiveDynamicTableFactoryTest.java | 4 +-
.../connectors/hive/HiveLookupJoinITCase.java | 6 +-
.../connectors/hive/HiveTableFactoryTest.java | 20 +--
.../jdbc/table/JdbcDynamicTableFactoryTest.java | 118 ++++++++--------
.../jdbc/table/JdbcDynamicTableSinkITCase.java | 22 +--
.../kafka/table/KafkaDynamicTableFactoryTest.java | 115 ++++++----------
.../table/UpsertKafkaDynamicTableFactoryTest.java | 110 ++++++---------
.../kinesis/table/KinesisDynamicTableFactory.java | 20 ++-
.../connectors/kinesis/table/KinesisOptions.java | 15 +-
.../table/RowDataFieldsKinesisPartitioner.java | 48 +++----
.../table/KinesisDynamicTableFactoryTest.java | 151 +++++++--------------
.../table/RowDataFieldsKinesisPartitionerTest.java | 66 ++++-----
.../confluent/RegistryAvroFormatFactoryTest.java | 56 +++-----
.../debezium/DebeziumAvroFormatFactoryTest.java | 51 ++-----
.../flink/formats/avro/AvroFormatFactoryTest.java | 50 ++-----
.../flink/formats/csv/CsvFormatFactoryTest.java | 74 ++++------
.../flink/formats/json/JsonFormatFactoryTest.java | 54 ++------
.../json/canal/CanalJsonFormatFactoryTest.java | 49 ++-----
.../debezium/DebeziumJsonFormatFactoryTest.java | 57 ++------
.../json/maxwell/MaxwellJsonFormatFactoryTest.java | 57 +++-----
.../table/factories/BlackHoleSinkFactoryTest.java | 32 ++---
.../factories/DataGenTableSourceFactoryTest.java | 115 +++++++---------
.../table/factories/PrintSinkFactoryTest.java | 27 ++--
.../apache/flink/table/catalog/CatalogManager.java | 8 +-
.../flink/table/catalog/DefaultSchemaResolver.java | 2 +-
.../catalog/CatalogBaseTableResolutionTest.java | 2 +-
.../flink/table/catalog/SchemaResolutionTest.java | 2 +-
.../apache/flink/table/catalog/ResolvedSchema.java | 3 +
.../apache/flink/table/catalog/WatermarkSpec.java | 7 +-
.../flink/table/factories/DynamicTableFactory.java | 27 +++-
.../apache/flink/table/factories/FactoryUtil.java | 16 ++-
.../expressions/utils/ResolvedExpressionMock.java | 4 +
.../flink/table/factories/FactoryUtilTest.java | 47 ++-----
.../flink/table/factories/utils/FactoryMocks.java | 114 ++++++++++++++++
.../exec/serde/CatalogTableJsonDeserializer.java | 2 +-
.../planner/plan/schema/CatalogSourceTable.java | 2 +-
.../filesystem/FileSystemTableFactoryTest.java | 59 +++-----
.../table/formats/raw/RawFormatFactoryTest.java | 64 +++------
46 files changed, 956 insertions(+), 1247 deletions(-)
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/factories/utils/FactoryMocks.java
