This is an automated email from the ASF dual-hosted git repository.
arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 15d22393 [FLINK-26534][table-planner] shuffle by sink's primary key
should cover the case that input changelog stream has a different parallelism
(#19006)
add 1a89976 [FLINK-26532][metrics][test] using the numRecordsSend counter
to get the correct metric
No new revisions were added by this update.
Summary of changes:
.../apache/flink/test/streaming/runtime/SinkMetricsITCase.java | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
