This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from f90fd6b [FLINK-15136][docs] Update the Chinese version of Working
with State TTL
add c93205b [FLINK-14649][kafka][es] Flatten all the connector properties
keys to make it easy to configure in DDL (#10468)
No new revisions were added by this update.
Summary of changes:
docs/dev/table/connect.md | 60 ++----
docs/dev/table/connect.zh.md | 60 ++----
docs/dev/table/sqlClient.md | 18 +-
docs/dev/table/sqlClient.zh.md | 18 +-
.../ElasticsearchUpsertTableSinkBase.java | 7 +
.../ElasticsearchUpsertTableSinkFactoryBase.java | 24 ++-
.../flink/table/descriptors/Elasticsearch.java | 19 +-
.../table/descriptors/ElasticsearchValidator.java | 65 ++++++-
...lasticsearchUpsertTableSinkFactoryTestBase.java | 98 +++++++---
.../flink/table/descriptors/ElasticsearchTest.java | 41 ++--
.../kafka/KafkaTableSourceSinkFactoryBase.java | 58 ++++--
.../org/apache/flink/table/descriptors/Kafka.java | 35 ++--
.../flink/table/descriptors/KafkaValidator.java | 98 ++++++++--
.../kafka/KafkaTableSourceSinkFactoryTestBase.java | 208 +++++++++++++++++----
.../apache/flink/table/descriptors/KafkaTest.java | 22 +--
.../test-scripts/kafka_sql_common.sh | 6 +-
.../test-scripts/test_sql_client.sh | 10 +-
.../test-scripts/test_sql_client_kafka_common.sh | 6 +-
flink-python/pyflink/table/table_environment.py | 4 +-
.../pyflink/table/tests/test_descriptor.py | 21 +--
.../apache/flink/table/api/TableEnvironment.java | 4 +-
21 files changed, 570 insertions(+), 312 deletions(-)
