All pull requests

Pull requests

• [CELEBORN-2514] Avoid rebuilding the tag store on every tag lookup

  module:master
  #3911·yew1eb opened Oct 28, 2026Contributor·2 tasks·

  ·

• [CELEBORN-2512] Fix RPC metrics never being removed because removal ignores the name label

  correctnessmodule:common
  #3910·yew1eb opened Oct 28, 2026Contributor·2 tasks done·

  ·

• [CELEBORN-2513] Fix Grafana panel querying the non-existent metrics_LocalFetchChunkTime_Max

  kind:deploy
  #3909·yew1eb opened Oct 28, 2026Contributor·1 of 2 tasks·

  ·

• [CELEBORN-2511] Fix labeled histograms sharing one reservoir and being missed in metrics count

  correctnessmodule:common
  #3908·yew1eb opened Oct 28, 2026Contributor·2 tasks done·

  ·

• [CELEBORN-2510] Fix ThreadStackTrace.toString dropping blockedByThreadId

  module:common
  #3907·yew1eb opened Oct 28, 2026Contributor·1 of 2 tasks·

  ·

• [CELEBORN-2509][CIP-13] Autoscaling: Add worker count calculation

  kind:documentationmodule:commonmodule:mastermodule:worker
  #3906·Kalvin2077 opened Oct 28, 2026Contributor·1 of 2 tasks·

  ·

• [CELEBORN-2508] Fail safely after AQE integrity validation errors

  correctnessmodule:client
  #3905·zaynt4606 opened Oct 28, 2026Contributor·2 tasks done·

  ·
  1

• Confirm MapperEnd against Spark's MapOutputTracker before counting it

  kind:documentationkind:inframodule:clientmodule:commonmodule:sparkmodule:tests
  #3904·saurabhd336 opened Oct 28, 2026Contributor·2 tasks·

  ·
  1

• [CELEBORN-2507] Fix hashCode/equals contract violation in CelebornCRC32, CommitMetadata and ReadData

  correctnessmodule:common
  #3903·yew1eb opened Oct 28, 2026Contributor·1 of 2 tasks·

  ·

• [CELEBORN-2506] Add user documentation for Celeborn Spark UI extension

  kind:documentation
  #3902·yew1eb opened Oct 27, 2026Contributor·1 of 2 tasks·

  ·
  1

• [CELEBORN-2392] Prevent false shuffle expiry during concurrent registration

  correctnessmodule:master
  #3901·wayne-x-wang opened Oct 27, 2026Contributor·2 tasks done·

  ·
  1

• [CELEBORN-1945] Prioritize flush tasks of committing REDUCE writers

  kind:documentationmodule:commonmodule:worker
  #3900·zaynt4606 opened Oct 26, 2026Contributor·1 of 2 tasks·

  ·

• [CELEBORN-2468] Add module-specific transport bootstrap configuration

  kind:documentationmodule:clientmodule:commonmodule:flinkmodule:worker
  #3894·Kalvin2077 opened Oct 22, 2026Contributor·1 of 2 tasks·

  ·
  7

• [CELEBORN-2469][CIP-13] Autoscaling: add worker stats collection

  kind:documentationmodule:commonmodule:mastermodule:worker
  #3858·Kalvin2077 opened Sep 24, 2026Contributor·1 of 2 tasks·

  ·
  8

• [CELEBORN-2464] Wire Kubernetes health probes into the Helm chart

  kind:deploy
  #3854·strelok89 opened Sep 17, 2026Contributor·1 of 2 tasks·

  ·
  7

• [CELEBORN-2465][SPARK] Proactively unregister shuffles on SQL query completion

  kind:documentationmodule:clientmodule:commonmodule:sparkmodule:tests
  #3853·yew1eb opened Sep 17, 2026Contributor·

  ·
  20

• [CELEBORN-2460] Reply SHUFFLE_EXPIRED for a released shuffle instead of an empty file group

  correctnessmodule:clientmodule:commonmodule:tests
  #3845·shlomitubul opened Sep 10, 2026Contributor·1 of 2 tasks·

  ·
  14

• [CELEBORN-2457][CIP-24] Adaptive partition write parallelism

  kind:documentationmodule:clientmodule:commonmodule:testsmodule:worker
  #3843·yew1eb opened Sep 8, 2026Contributor·1 of 2 tasks·

  ·
  1

• [CELEBORN-2445] Support overriding decommission forceExitTimeout via the worker exit API

  kind:documentationmodule:climodule:openapimodule:servicemodule:worker
  #3828·cxzl25 opened Aug 26, 2026Contributor·2 tasks·

  ·
  19

• [CELEBORN-2388] Decouple inter-master Ratis TLS into its own SSL module

  module:commonmodule:master
  #3767·shellfish007 opened Jul 23, 2026·

  ·
  10

• [CELEBORN-2389] Track S3 resource consumption in per-app/per-user metrics

  module:commonmodule:mastermodule:worker
  #3766·shellfish007 opened Jul 23, 2026·

  ·
  3

• [CELEBORN-2386] Pass peer hostname to SSLEngine for SNI support

  module:common
  #3764·shellfish007 opened Jul 23, 2026·

  ·
  5

• [CELEBORN-2349] Support worker supplied tags and TagsManager hardening

  kind:documentationmodule:commonmodule:mastermodule:worker
  #3719·s0nskar opened Jun 5, 2026Contributor·1 of 2 tasks·

  ·
  35

• [CELEBORN-2065] Worker should support wait partition sort asynchronously

  module:worker
  #3652·leixm opened Apr 7, 2026Contributor·

  ·
  16