-
Notifications
You must be signed in to change notification settings - Fork 410
Pull requests: apache/celeborn
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
[CELEBORN-1721][FOLLOWUP] Return softsplit if there is no hardsplit for pushMergeData
module:client
module:worker
#3342
opened Jun 20, 2025 by
RexXiong
Loading…
[CELEBORN-2040] Avoid throw FetchFailedException when GetReducerFileGroupResponse failed via broadcast
module:client
module:common
module:spark
#3341
opened Jun 20, 2025 by
vastian180
Loading…
[CELEBORN-1056][FOLLOWUP] Support testing of dynamic configuration management cli
kind:build
module:cli
module:service
#3340
opened Jun 20, 2025 by
SteNicholas
Loading…
[CIP-19][CELEBORN-1939] CongestionController should not limit user push speed when worker load is low
module:common
module:service
module:worker
#3337
opened Jun 17, 2025 by
leixm
Loading…
[CIP-19][CELEBORN-1937] QuotaManager should support app threshold
kind:documentation
module:common
module:master
module:service
#3336
opened Jun 17, 2025 by
leixm
Loading…
[CELEBORN-1166][FOLLOWUP] Avoid calling parmap when setup endpoint
module:client
#3334
opened Jun 17, 2025 by
SteNicholas
•
Draft
[CELEBORN-2036]Fix NPE when TransportMessage has null payload
module:common
#3330
opened Jun 13, 2025 by
Jraaay
Loading…
[CELEBORN-2032] Create reader should change to peer by taskAttemptId
module:client
module:spark
#3320
opened Jun 10, 2025 by
leixm
Loading…
[MINOR] Fixed some of the maven warnings
kind:build
module:client
module:flink
module:mr
module:openapi
module:service
module:spark
module:tez
module:worker
#3310
opened Jun 4, 2025 by
s0nskar
Loading…
[CELEBORN-1768][SPARK-3][WRITER] Refactoring Shuffle Writer to extract common methods
module:client
module:spark
#3306
opened Jun 3, 2025 by
zwangsheng
Loading…
[CELEBORN-2016] Add cooldown time in worker shutdown
kind:documentation
module:common
module:worker
#3294
opened May 27, 2025 by
s0nskar
Loading…
[DRAFT] [FEATURE] Inverted index based reduce partition data writer / reader
module:client
module:common
module:worker
stale
#3279
opened May 25, 2025 by
saurabhd336
Loading…
[CELEBORN-894] End to End Integrity Checks
kind:documentation
module:client
module:common
module:flink
module:mr
module:spark
module:tests
module:tez
module:worker
#3261
opened May 15, 2025 by
gauravkm
Loading…
[WIP] Dynamically adjust partition write parallelism
module:client
module:common
module:tests
module:worker
#3260
opened May 14, 2025 by
ErikFang
Loading…
[CELEBORN-1917] supports celeborn.client.push.maxBytesSizeInFlight
kind:documentation
module:client
module:common
module:flink
#3248
opened May 8, 2025 by
DDDominik
Loading…
CELEBORN-1991: add retries for registerShuffle on the lifecycleManager
kind:documentation
module:client
module:common
module:spark
#3238
opened Apr 28, 2025 by
shahryart
Loading…
[CELEBORN-1984] Merge ResourceRequest to transportMessageProtobuf
module:common
module:master
#3231
opened Apr 25, 2025 by
zhaohehuhu
Loading…
[RFT] Enable run java UT (not a formal PR, just for discussion purposes)
kind:build
#3219
opened Apr 22, 2025 by
vastian180
Loading…
Set max memory of SortBasedPusher based off Spark configs
kind:documentation
module:client
module:common
module:spark
#3203
opened Apr 7, 2025 by
helenweng-stripe
Loading…
[CELEBORN-1903] Enable connection heartbeat and close idle connection
kind:documentation
module:client
module:common
module:flink
module:service
module:worker
#3148
opened Mar 11, 2025 by
Austinfjq
Loading…
[CELEBORN-894] Add checksum for shuffle data
kind:documentation
module:client
module:common
module:flink
module:worker
#2979
opened Dec 8, 2024 by
jiang13021
Loading…
ProTip!
Exclude everything labeled
bug with -label:bug.