You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2020/07/10 03:53:53 UTC
[flink] branch master updated (e162bd7 -> fce502c)
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 e162bd7 [FLINK-18453][tests] Fix overflow of AggregateITCase#testAggregationCodeSplit
add fce502c [FLINK-15221][kafka][table] Support sink delivery semantic for Kafka in Table API
No new revisions were added by this update.
Summary of changes:
docs/dev/table/connectors/kafka.md | 20 +++++++++
docs/dev/table/connectors/kafka.zh.md | 23 +++++++++-
.../kafka/table/Kafka010DynamicSink.java | 6 ++-
.../kafka/table/Kafka010DynamicTableFactory.java | 18 +++++++-
.../table/Kafka010DynamicTableFactoryTest.java | 50 +++++++++++++++++++++-
.../kafka/table/Kafka011DynamicSink.java | 19 +++++---
.../kafka/table/Kafka011DynamicTableFactory.java | 6 ++-
.../table/Kafka011DynamicTableFactoryTest.java | 6 ++-
.../kafka/table/KafkaDynamicSinkBase.java | 22 +++++++---
.../kafka/table/KafkaDynamicTableFactoryBase.java | 17 +++++---
.../connectors/kafka/table/KafkaOptions.java | 44 +++++++++++++++++++
.../connectors/kafka/table/KafkaSinkSemantic.java} | 29 +++++++------
.../table/KafkaDynamicTableFactoryTestBase.java | 40 ++++++++++++++---
.../connectors/kafka/table/KafkaDynamicSink.java | 16 ++++---
.../kafka/table/KafkaDynamicTableFactory.java | 6 ++-
.../kafka/table/KafkaDynamicTableFactoryTest.java | 6 ++-
16 files changed, 272 insertions(+), 56 deletions(-)
copy flink-connectors/{flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGenerator.java => flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaSinkSemantic.java} (59%)