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 82582b3a7b7 [FLINK-36364][state/forst] Do not reuse serialized key in
Forst map state and/or other namespaces (#25394)
add 797688008de [FLINK-36287] Migrate SinkITCase to AssertJ
add 9d21878befa [FLINK-36287] Disallow UC for inner sink channels
No new revisions were added by this update.
Summary of changes:
.../streaming/api/graph/StreamGraphGenerator.java | 9 +-
.../ForwardForConsecutiveHashPartitioner.java | 5 +
.../runtime/partitioner/StreamPartitioner.java | 15 +++
.../translators/SinkTransformationTranslator.java | 65 ++++++++++++-
.../SinkTransformationTranslatorITCaseBase.java | 5 +
.../SinkV1TransformationTranslatorITCase.java | 8 +-
.../operators/sink/CommitterOperatorTestBase.java | 42 +--------
.../flink/test/streaming/runtime/SinkITCase.java | 101 ++++++++++++---------
8 files changed, 152 insertions(+), 98 deletions(-)
