Skip to content

Pull requests: apache/celeborn

New pull request New
Clear current search query, filters, and sorts
20 Open 2,732 Closed
20 Open 2,732 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

[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… updated May 26, 2025
52
[CELEBORN-1768][WRITER] Refactoring Shuffle Writer to extract common methods module:client module:spark
#2985 opened Dec 9, 2024 by zwangsheng Loading… updated May 26, 2025
14
CELEBORN-1334 [CIP-12] Support HARD_SPLIT in PushMergedData should not support new version client with old version worker
#3171 opened Mar 25, 2025 by AngersZhuuuu Loading… updated May 26, 2025
6
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… updated May 26, 2025
8
[RFT] Enable run java UT (not a formal PR, just for discussion purposes) kind:build
#3219 opened Apr 22, 2025 by vastian180 Loading… updated May 26, 2025
3
[CELEBORN-1841][FOLLOWUP] Support custom implementation of EventExecutorChooser to avoid deadlock when calling await in EventLoop thread for EpollEventLoopGroup module:common
#3220 opened Apr 22, 2025 by SteNicholas • Draft updated May 26, 2025
3
[CELEBORN-1984] Merge ResourceRequest to transportMessageProtobuf module:common module:master
#3231 opened Apr 25, 2025 by zhaohehuhu Loading… updated May 26, 2025
14
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… updated May 26, 2025
2
[CELEBORN-1997] RemoteShuffleInputGateDelegation should regard CelebornIOException as data consumption error for RestartPipelinedRegionFailoverStrategy module:client module:flink
#3256 opened May 14, 2025 by SteNicholas Loading… updated May 26, 2025
4
[WIP] Dynamically adjust partition write parallelism module:client module:common module:tests module:worker
#3260 opened May 14, 2025 by ErikFang Loading… updated May 26, 2025
[DRAFT] [FEATURE] Inverted index based reduce partition data writer / reader module:client module:common module:worker
#3279 opened May 25, 2025 by saurabhd336 Loading… updated May 26, 2025
6
[CELEBORN-3288] Fix Deserialization Vulnerability module:service
#3288 opened May 26, 2025 by th555555 Loading… updated May 27, 2025
1
[CELEBORN-1917] supports celeborn.client.push.maxBytesSizeInFlight module:client module:common module:flink
#3248 opened May 8, 2025 by DDDominik Loading… updated May 27, 2025
3
[CELEBORN-2016] Add cooldown time in worker shutdown kind:documentation module:common module:worker
#3294 opened May 27, 2025 by s0nskar Loading… updated May 27, 2025
1
[CELEBORN-2017][HELM] Add namespace to the metadata kind:deploy
#3295 opened May 28, 2025 by ChenYi015 Loading… updated May 28, 2025
[CELEBORN-2003] Add retry mechanism when completing S3 multipart upload
#3293 opened May 27, 2025 by ashangit Loading… updated May 28, 2025
1
[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… updated May 29, 2025
11
[CELEBORN-894] End to End Integrity Checks module:client module:common module:flink module:mr module:spark module:tests module:worker
#3261 opened May 15, 2025 by gauravkm Loading… updated May 29, 2025
20
[CELEBORN-2014] updateInterruptionNotice REST API module:common module:master module:openapi module:service
#3285 opened May 26, 2025 by akpatnam25 Loading… updated May 29, 2025
10
[CELEBORN-2005][FOLLOWUP] Introduce ShuffleMetricGroup for numBytesIn, numBytesOut, numRecordsOut, numBytesInPerSecond, numBytesOutPerSecond, numRecordsOutPerSecond metrics kind:documentation module:client module:common module:flink
#3296 opened May 28, 2025 by SteNicholas Loading… updated May 29, 2025
4
ProTip! What’s not been updated in a month: updated:<2025-04-28.