You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2020/01/16 09:42:10 UTC
[flink] branch master updated (9a58ded -> 4717c51)
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 9a58ded [FLINK-14843][e2e] Harden bucketing sink e2e test
add 26c9082 [FLINK-15220][Table][Kafka] Add startup timestamp in KafkaTableSource
add 4717c51 [FLINK-15220][Table,Kafka,Python] Add startup timestamp in KafkaTableSource in python API
No new revisions were added by this update.
Summary of changes:
docs/dev/table/connect.md | 12 +++-
docs/dev/table/connect.zh.md | 11 +++-
.../connectors/kafka/Kafka010TableSource.java | 8 ++-
.../kafka/Kafka010TableSourceSinkFactory.java | 6 +-
.../kafka/Kafka010TableSourceSinkFactoryTest.java | 6 +-
.../connectors/kafka/Kafka011TableSource.java | 8 ++-
.../kafka/Kafka011TableSourceSinkFactory.java | 6 +-
.../kafka/Kafka011TableSourceSinkFactoryTest.java | 6 +-
.../connectors/kafka/KafkaTableSourceBase.java | 24 +++++--
.../kafka/KafkaTableSourceSinkFactoryBase.java | 16 ++++-
.../org/apache/flink/table/descriptors/Kafka.java | 19 ++++++
.../flink/table/descriptors/KafkaValidator.java | 26 ++++++++
.../kafka/KafkaTableSourceSinkFactoryTestBase.java | 9 ++-
.../apache/flink/table/descriptors/KafkaTest.java | 18 ++++-
.../table/descriptors/KafkaValidatorTest.java | 76 ++++++++++++++++++++++
.../connectors/kafka/KafkaTableSource.java | 6 +-
.../kafka/KafkaTableSourceSinkFactory.java | 6 +-
.../kafka/KafkaTableSourceSinkFactoryTest.java | 6 +-
flink-python/pyflink/table/descriptors.py | 20 ++++++
19 files changed, 255 insertions(+), 34 deletions(-)
create mode 100644 flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/table/descriptors/KafkaValidatorTest.java