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/09/18 07:56:44 UTC

[flink] branch master updated (79181b8 -> a3b4c93)

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 79181b8  [hotfix][docs][rest] Update rest_v1_dispatcher.html
     add a3b4c93  [FLINK-19002][canal][json] Support to only read changelogs of specific database and table for canal-json format

No new revisions were added by this update.

Summary of changes:
 docs/dev/table/connectors/formats/canal.md         | 16 +++-
 docs/dev/table/connectors/formats/canal.zh.md      | 14 ++++
 .../json/canal/CanalJsonDeserializationSchema.java | 97 +++++++++++++++++++++-
 .../formats/json/canal/CanalJsonFormatFactory.java | 29 +++++--
 .../json/canal/CanalJsonFormatFactoryTest.java     | 91 ++++++++++++--------
 .../json/canal/CanalJsonSerDeSchemaTest.java       | 24 ++++--
 .../src/test/resources/canal-data-filter-table.txt | 14 ++++
 7 files changed, 235 insertions(+), 50 deletions(-)
 create mode 100644 flink-formats/flink-json/src/test/resources/canal-data-filter-table.txt