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 9ef8873 [FLINK-26610][connectors/filesystem] Do not add state
handlers for file compaction if compaction is not explicitly disabled.
add 15d22393 [FLINK-26534][table-planner] shuffle by sink's primary key
should cover the case that input changelog stream has a different parallelism
(#19006)
No new revisions were added by this update.
Summary of changes:
.../plan/nodes/exec/common/CommonExecSink.java | 10 +-
.../planner/plan/stream/sql/TableSinkTest.xml | 188 +++++++++++++++++++++
.../planner/plan/stream/sql/TableSinkTest.scala | 100 +++++++++++
3 files changed, 293 insertions(+), 5 deletions(-)
