This is an automated email from the ASF dual-hosted git repository.
yuanmei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 0eee3432b42 [FLINK-30041][ci] Setup conjars https mirror
add 594302b01b0 [FLINK-29437] Align the partition of data before and after
the Kafka Shuffle
add 0b816680e51 document the parallelism setting part
No new revisions were added by this update.
Summary of changes:
.../internals/KafkaTopicPartitionAssigner.java | 9 ++++--
.../kafka/shuffle/FlinkKafkaShuffle.java | 6 +++-
.../kafka/shuffle/FlinkKafkaShuffleProducer.java | 15 ++++++++-
.../kafka/shuffle/KafkaShuffleTestBase.java | 37 ++++++++++++++++++----
4 files changed, 55 insertions(+), 12 deletions(-)
