You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by lz...@apache.org on 2022/07/28 04:51:15 UTC

[flink-table-store] branch release-0.2 updated (ceab29fd -> 6de3067a)

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a change to branch release-0.2
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git


    from ceab29fd [FLINK-28717] Add null checking for all field getters
     add 6de3067a [FLINK-28712] Default Changelog all when changelog producer is input

No new revisions were added by this update.

Summary of changes:
 docs/content/docs/development/streaming-query.md   |  30 +++++-
 docs/static/img/changelog-producer-input.png       | Bin 0 -> 318448 bytes
 docs/static/img/changelog-producer-none.png        | Bin 0 -> 297802 bytes
 .../table/store/connector/sink/TableStoreSink.java |  32 +++---
 .../store/connector/source/TableStoreSource.java   |  10 +-
 .../table/store/connector/ChangelogModeTest.java   | 115 +++++++++++++++++++++
 6 files changed, 165 insertions(+), 22 deletions(-)
 create mode 100644 docs/static/img/changelog-producer-input.png
 create mode 100644 docs/static/img/changelog-producer-none.png
 create mode 100644 flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/ChangelogModeTest.java