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 f367a22 [FLINK-22891][runtime] Using CompletableFuture to sync the
scheduling of checkResourceRequirements
add a942322 [FLINK-25313][connector-elasticsearch] Remove legacy
Elasticseach connector
add 77901ef [FLINK-23513][connector-kafka] Remove legacy Kafka connector
add 716b9f7 [FLINK-23513] Deprecate legacy CSV connector
add 4fc0d22 [FLINK-23513][table-common] Remove unused descriptor classes
add 3ae67a4 [FLINK-23513] Remove format descriptors
add 03ceeb9 [FLINK-23513][docs] Fix docs due to new CSV connector
add bdde9a0 [FLINK-23513][table-common] Remove FunctionDescriptor
add a9152be [FLINK-23513][table-common] Remove CoreModuleDescriptor
add 1695d06 [FLINK-23513][table-common] Deprecate remaining descriptors
add e394f46 [hotfix][table-api-java] Missing @Test annotation in
TableEnvironmentTest
add c3ce777 [FLINK-23513][table-api-java] Remove
StreamTableDescriptorValidator
add 706cd67 [FLINK-23513][e2e] Remove legacy factory check in
test_sql_client.sh
No new revisions were added by this update.
Summary of changes:
.../docs/dev/python/table_api_tutorial.md | 7 +-
docs/content.zh/docs/dev/table/catalogs.md | 72 +-
docs/content/docs/dev/python/table_api_tutorial.md | 11 +-
docs/content/docs/dev/table/catalogs.md | 75 +-
.../ElasticsearchUpsertTableSinkBase.java | 523 ---------
.../ElasticsearchUpsertTableSinkFactoryBase.java | 383 ------
.../flink/table/descriptors/Elasticsearch.java | 325 -----
.../table/descriptors/ElasticsearchValidator.java | 200 ----
...lasticsearchUpsertTableSinkFactoryTestBase.java | 241 ----
.../flink/table/descriptors/ElasticsearchTest.java | 159 ---
.../Elasticsearch6UpsertTableSink.java | 265 -----
.../Elasticsearch6UpsertTableSinkFactory.java | 75 --
.../org.apache.flink.table.factories.TableFactory | 16 -
.../Elasticsearch6UpsertTableSinkFactoryTest.java | 238 ----
.../Elasticsearch7UpsertTableSink.java | 280 -----
.../Elasticsearch7UpsertTableSinkFactory.java | 74 --
.../org.apache.flink.table.factories.TableFactory | 16 -
.../Elasticsearch7UpsertTableSinkFactoryTest.java | 237 ----
.../flink/table/catalog/hive/HiveCatalogTest.java | 31 +-
.../streaming/connectors/kafka/KafkaTableSink.java | 59 -
.../connectors/kafka/KafkaTableSinkBase.java | 164 ---
.../connectors/kafka/KafkaTableSource.java | 108 --
.../connectors/kafka/KafkaTableSourceBase.java | 382 ------
.../kafka/KafkaTableSourceSinkFactory.java | 90 --
.../kafka/KafkaTableSourceSinkFactoryBase.java | 465 --------
.../org/apache/flink/table/descriptors/Kafka.java | 315 -----
.../flink/table/descriptors/KafkaValidator.java | 250 ----
.../org.apache.flink.table.factories.TableFactory | 16 -
.../kafka/KafkaTableSourceSinkFactoryTest.java | 92 --
.../kafka/KafkaTableSourceSinkFactoryTestBase.java | 622 ----------
.../connectors/kafka/table/KafkaTableITCase.java | 145 +--
.../apache/flink/table/descriptors/KafkaTest.java | 115 --
.../table/descriptors/KafkaValidatorTest.java | 76 --
.../org.apache.flink.table.factories.TableFactory | 16 -
.../test-scripts/test_sql_client.sh | 9 -
.../flink/formats/avro/AvroRowFormatFactory.java | 94 --
.../org/apache/flink/table/descriptors/Avro.java | 75 --
.../flink/table/descriptors/AvroValidator.java | 49 -
.../org.apache.flink.table.factories.TableFactory | 16 -
.../formats/avro/AvroRowFormatFactoryTest.java | 96 --
.../apache/flink/table/descriptors/AvroTest.java | 74 --
.../flink/formats/csv/CsvRowFormatFactory.java | 159 ---
.../org/apache/flink/table/descriptors/Csv.java | 194 ---
.../flink/table/descriptors/CsvValidator.java | 78 --
.../org.apache.flink.table.factories.TableFactory | 16 -
.../flink/formats/csv/CsvRowFormatFactoryTest.java | 188 ---
.../apache/flink/table/descriptors/CsvTest.java | 103 --
.../flink/formats/json/JsonRowFormatFactory.java | 114 --
.../org/apache/flink/table/descriptors/Json.java | 158 ---
.../flink/table/descriptors/JsonValidator.java | 71 --
.../org.apache.flink.table.factories.TableFactory | 16 -
.../formats/json/JsonRowFormatFactoryTest.java | 181 ---
.../apache/flink/table/descriptors/JsonTest.java | 147 ---
flink-python/dev/pip_test_code.py | 2 +-
flink-python/pyflink/table/descriptors.py | 1237 +-------------------
.../pyflink/table/tests/test_descriptor.py | 688 +----------
.../descriptors/python/CustomFormatDescriptor.java | 69 --
.../org/apache/flink/table/descriptors/OldCsv.java | 300 -----
.../flink/table/descriptors/OldCsvValidator.java | 15 +-
.../flink/table/descriptors/RowtimeValidator.java | 7 +-
.../flink/table/descriptors/SchemaValidator.java | 7 +-
.../table/sinks/CsvAppendTableSinkFactory.java | 15 +-
.../table/sinks/CsvBatchTableSinkFactory.java | 9 +-
.../org/apache/flink/table/sinks/CsvTableSink.java | 11 +-
.../flink/table/sinks/CsvTableSinkFactoryBase.java | 19 +-
.../table/sources/CsvAppendTableSourceFactory.java | 18 +-
.../table/sources/CsvBatchTableSourceFactory.java | 12 +-
.../apache/flink/table/sources/CsvTableSource.java | 7 +
.../table/sources/CsvTableSourceFactoryBase.java | 19 +-
.../apache/flink/table/module/ModuleManager.java | 5 +-
.../flink/table/api/TableEnvironmentTest.java | 27 +-
.../flink/table/module/ModuleManagerTest.java | 51 +-
.../flink/table/utils/FormatDescriptorMock.java | 44 -
.../flink/table/utils/TableSourceFactoryMock.java | 98 --
.../org.apache.flink.table.factories.TableFactory | 1 -
.../flink/table/descriptors/ClassInstance.java | 225 ----
.../table/descriptors/ClassInstanceValidator.java | 68 --
.../table/descriptors/ConnectorDescriptor.java | 70 --
.../descriptors/ConnectorDescriptorValidator.java | 3 +-
.../table/descriptors/CoreModuleDescriptor.java | 38 -
.../descriptors/CoreModuleDescriptorValidator.java | 30 -
.../apache/flink/table/descriptors/Descriptor.java | 4 +
.../flink/table/descriptors/DescriptorBase.java | 31 -
.../table/descriptors/DescriptorValidator.java | 3 +
.../apache/flink/table/descriptors/FileSystem.java | 56 -
.../table/descriptors/FileSystemValidator.java | 14 +-
.../flink/table/descriptors/FormatDescriptor.java | 58 -
.../descriptors/FormatDescriptorValidator.java | 53 -
.../table/descriptors/FunctionDescriptor.java | 55 -
.../descriptors/FunctionDescriptorValidator.java | 51 -
.../table/descriptors/HierarchyDescriptor.java | 34 -
.../descriptors/HierarchyDescriptorValidator.java | 43 -
.../flink/table/descriptors/LiteralValue.java | 185 ---
.../table/descriptors/LiteralValueValidator.java | 158 ---
.../flink/table/descriptors/ModuleDescriptor.java | 14 +-
.../descriptors/ModuleDescriptorValidator.java | 1 +
.../table/descriptors/PythonFunctionValidator.java | 33 -
.../apache/flink/table/descriptors/Rowtime.java | 7 +-
.../org/apache/flink/table/descriptors/Schema.java | 3 +
.../StreamTableDescriptorValidator.java | 60 -
.../flink/table/descriptors/TableDescriptor.java | 159 ---
.../flink/table/factories/TableFactoryService.java | 23 +-
.../table/factories/TableFormatFactoryBase.java | 7 +-
.../flink/table/functions/FunctionService.java | 223 ----
.../flink/table/module/CoreModuleFactory.java | 7 +-
.../table/descriptors/DescriptorTestBase.java | 4 +
.../module/CoreModuleDescriptorTest.java | 55 -
.../factories/TableSinkFactoryServiceTest.java | 12 +-
.../table/factories/TestTableSinkFactory.java | 6 +-
.../factories/module/CoreModuleFactoryTest.java | 8 +-
.../flink/table/functions/FunctionServiceTest.java | 171 ---
111 files changed, 323 insertions(+), 12291 deletions(-)
delete mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java
delete mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkFactoryBase.java
delete mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/table/descriptors/Elasticsearch.java
delete mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/table/descriptors/ElasticsearchValidator.java
delete mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkFactoryTestBase.java
delete mode 100644
flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/table/descriptors/ElasticsearchTest.java
delete mode 100644
flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSink.java
delete mode 100644
flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSinkFactory.java
delete mode 100644
flink-connectors/flink-connector-elasticsearch6/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
delete mode 100644
flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSinkFactoryTest.java
delete mode 100644
flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSink.java
delete mode 100644
flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSinkFactory.java
delete mode 100644
flink-connectors/flink-connector-elasticsearch7/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
delete mode 100644
flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSinkFactoryTest.java
delete mode 100644
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSink.java
delete mode 100644
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkBase.java
delete mode 100644
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
delete mode 100644
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceBase.java
delete mode 100644
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactory.java
delete mode 100644
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactoryBase.java
delete mode 100644
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/table/descriptors/Kafka.java
delete mode 100644
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/table/descriptors/KafkaValidator.java
delete mode 100644
flink-connectors/flink-connector-kafka/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
delete mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactoryTest.java
delete mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactoryTestBase.java
delete mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/table/descriptors/KafkaTest.java
delete mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/table/descriptors/KafkaValidatorTest.java
delete mode 100644
flink-connectors/flink-connector-kafka/src/test/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
delete mode 100644
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowFormatFactory.java
delete mode 100644
flink-formats/flink-avro/src/main/java/org/apache/flink/table/descriptors/Avro.java
delete mode 100644
flink-formats/flink-avro/src/main/java/org/apache/flink/table/descriptors/AvroValidator.java
delete mode 100644
flink-formats/flink-avro/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
delete mode 100644
flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroRowFormatFactoryTest.java
delete mode 100644
flink-formats/flink-avro/src/test/java/org/apache/flink/table/descriptors/AvroTest.java
delete mode 100644
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowFormatFactory.java
delete mode 100644
flink-formats/flink-csv/src/main/java/org/apache/flink/table/descriptors/Csv.java
delete mode 100644
flink-formats/flink-csv/src/main/java/org/apache/flink/table/descriptors/CsvValidator.java
delete mode 100644
flink-formats/flink-csv/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
delete mode 100644
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvRowFormatFactoryTest.java
delete mode 100644
flink-formats/flink-csv/src/test/java/org/apache/flink/table/descriptors/CsvTest.java
delete mode 100644
flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowFormatFactory.java
delete mode 100644
flink-formats/flink-json/src/main/java/org/apache/flink/table/descriptors/Json.java
delete mode 100644
flink-formats/flink-json/src/main/java/org/apache/flink/table/descriptors/JsonValidator.java
delete mode 100644
flink-formats/flink-json/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
delete mode 100644
flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonRowFormatFactoryTest.java
delete mode 100644
flink-formats/flink-json/src/test/java/org/apache/flink/table/descriptors/JsonTest.java
delete mode 100644
flink-python/src/main/java/org/apache/flink/table/descriptors/python/CustomFormatDescriptor.java
delete mode 100644
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/descriptors/OldCsv.java
delete mode 100644
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/utils/FormatDescriptorMock.java
delete mode 100644
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/utils/TableSourceFactoryMock.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/ClassInstance.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/ClassInstanceValidator.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/ConnectorDescriptor.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/CoreModuleDescriptor.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/CoreModuleDescriptorValidator.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/DescriptorBase.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/FileSystem.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/FormatDescriptor.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/FormatDescriptorValidator.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/FunctionDescriptor.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/FunctionDescriptorValidator.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/HierarchyDescriptor.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/HierarchyDescriptorValidator.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/LiteralValue.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/LiteralValueValidator.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/PythonFunctionValidator.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/StreamTableDescriptorValidator.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/TableDescriptor.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/FunctionService.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/descriptors/module/CoreModuleDescriptorTest.java
delete mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/functions/FunctionServiceTest.java
