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/05/28 06:09:20 UTC

[flink] branch master updated (be7b7ae -> f47ffc2)

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 be7b7ae  [FLINK-16086][docs-zh] Translate "Temporal Tables" page of "Streaming Concepts" into Chinese
     add f47ffc2  [FLINK-17689][kafka][table] Add integration tests for changelog source and formats (#12284)

No new revisions were added by this update.

Summary of changes:
 .../connectors/kafka/table/KafkaTableTestBase.java |  59 ++++----
 .../connectors/kafka/table/KafkaTableITCase.java   | 156 +++++++++++++++++++++
 .../resources/debezium-data-schema-exclude.txt     |   0
 flink-table/flink-table-planner-blink/pom.xml      |   9 ++
 .../factories/TestValuesRuntimeFunctions.java      |  26 +++-
 .../planner/factories/TestValuesTableFactory.java  |  86 ++++++------
 .../planner/plan/stream/sql/TableScanTest.xml      |  27 ++++
 .../planner/plan/stream/sql/TableScanTest.scala    |  58 ++++++++
 .../runtime/stream/sql/AggregateITCase.scala       |  23 +--
 .../planner/runtime/stream/sql/JoinITCase.scala    |  46 +++++-
 .../runtime/stream/sql/TableSourceITCase.scala     |   2 +-
 .../runtime/stream/table/TableSinkITCase.scala     |   2 +-
 .../table/planner/runtime/utils/TestData.scala     |  27 +++-
 13 files changed, 431 insertions(+), 90 deletions(-)
 copy {flink-formats/flink-json => flink-connectors/flink-connector-kafka}/src/test/resources/debezium-data-schema-exclude.txt (100%)