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/03 13:16:09 UTC
[flink] branch master updated (7e1306c -> e089945)

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 7e1306c  [FLINK-18462][table-planner-blink] Improve the exception message when INSERT INTO mismatch types for empty char
     add e089945  [FLINK-18461][table-planner-blink] Fix Changelog source can't be insert into upsert sink

No new revisions were added by this update.

Summary of changes:
 .../executor/BufferReduceStatementExecutor.java    | 108 ++++++++
 .../jdbc/table/JdbcDynamicOutputFormatBuilder.java | 220 +++++++++++++++
 .../connector/jdbc/table/JdbcDynamicTableSink.java |   3 +-
 .../jdbc/table/JdbcRowDataOutputFormat.java        | 296 ---------------------
 ...tTest.java => JdbcDynamicOutputFormatTest.java} |  23 +-
 .../jdbc/table/JdbcDynamicTableSinkITCase.java     |  54 ++++
 .../FlinkChangelogModeInferenceProgram.scala       |  14 +-
 .../planner/plan/stream/sql/TableScanTest.xml      | 182 ++++++++-----
 .../planner/plan/stream/sql/TableScanTest.scala    |  54 +++-
 .../runtime/stream/sql/AggregateITCase.scala       |  82 +-----
 .../runtime/stream/sql/ChangelogSourceITCase.scala | 196 ++++++++++++++
 .../runtime/stream/sql/TableSourceITCase.scala     |  31 ---
 12 files changed, 767 insertions(+), 496 deletions(-)
 create mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/BufferReduceStatementExecutor.java
 create mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicOutputFormatBuilder.java
 delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataOutputFormat.java
 rename flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/{JdbcRowDataOutputFormatTest.java => JdbcDynamicOutputFormatTest.java} (95%)
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/ChangelogSourceITCase.scala