This is an automated email from the ASF dual-hosted git repository.
nicholasjiang pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/celeborn.git
from da84baed4 [CELEBORN-2027] Allow CelebornShuffleReader to decompress
data on demand
add feba7baec [CELEBORN-2029][FLINK] Some minor optimizations in the Flink
integration
No new revisions were added by this update.
Summary of changes:
.../plugin/flink/client/FlinkShuffleClientImpl.java | 10 +++++-----
.../plugin/flink/tiered/CelebornTierProducerAgent.java | 3 +++
.../plugin/flink/tiered/CelebornTierProducerAgent.java | 3 +++
.../service/deploy/worker/storage/MapPartitionData.java | 17 ++++++++++-------
.../deploy/worker/storage/MapPartitionDataReader.java | 13 +++++++++----
5 files changed, 30 insertions(+), 16 deletions(-)
