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 2021/12/08 09:06:24 UTC

[flink] branch master updated (a4299a2 -> 9e76585)

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

lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from a4299a2  [hotfix][table-common] Fix typo in ProjectableDecodingFormat
     add 9e76585  [FLINK-20370][table] part2: introduce 'table.exec.sink.keyed-shuffle' option to auto keyby on sink's pk if parallelism are not the same for insertOnly input

No new revisions were added by this update.

Summary of changes:
 .../generated/execution_config_configuration.html  |   7 +
 .../table/api/config/ExecutionConfigOptions.java   |  33 +++
 .../plan/nodes/exec/common/CommonExecSink.java     |  78 +++---
 .../planner/factories/TestValuesTableFactory.java  |   2 +-
 .../org.apache.flink.table.factories.Factory       |   1 +
 .../planner/plan/stream/sql/TableSinkTest.xml      | 272 +++++++++++++++++++--
 .../plan/stream/sql/join/TemporalJoinTest.xml      |  39 +++
 .../planner/plan/stream/sql/TableSinkTest.scala    | 195 ++++++++++++++-
 .../plan/stream/sql/join/TemporalJoinTest.scala    |  64 ++++-
 .../runtime/stream/sql/ChangelogSourceITCase.scala |   5 +-
 .../runtime/stream/table/TableSinkITCase.scala     |  49 +++-
 .../flink/table/planner/utils/TableTestBase.scala  |  56 +++--
 12 files changed, 715 insertions(+), 86 deletions(-)