Google Git
Sign in
apache/celeborn/HEAD
  1. 2b5dc8d [CELEBORN-2308] Bump commons-lang3 version from 3.17.0 to 3.20.0 by sychen · 32 hours ago main
  2. f0c8139 [CELEBORN-2371] Bound Spark batch-open client creation retries and stop them on interruption by Chao Sun · 6 days ago
  3. 76ce745 [CELEBORN-2380] Support JmxSink for exposing metrics as JMX MBeans by senthh · 6 days ago
  4. 59413d0 [CELEBORN-2385] Guard ByteBufAllocator cast in ChannelsLimiter trim path by sychen · 7 days ago
  5. 17f7d4f [CELEBORN-2379] Keep sbt and maven dependency lists in sync and cross-check both in CI by sychen · 14 days ago
  6. d77543e [CELEBORN-2382] Authorize `PbReviseLostShuffles` to prevent cross-application metadata modification by Kalvin2077 · 2 weeks ago
  7. 3aa2593 [CELEBORN-2383] Support Spark 4.2 by Nicholas Jiang · 2 weeks ago
  8. 50c18eb [CELEBORN-2381] Authorize PbApplicationMetaRequest to prevent secret disclosure by Nicholas Jiang · 2 weeks ago
  9. da8c1ce [CELEBORN-2362] Fix Flaky CI/CD by afterincomparableyum · 2 weeks ago
  10. b2f1da8 [CELEBORN-2377] Support Heartbeat message decoding in C++ client by yz · 3 weeks ago
  11. 1e715b2 [CELEBORN-2329][CIP22] Encryption at Rest Spark Impl by Aravind Patnam · 3 weeks ago
  12. a9055ae [CELEBORN-2374] Bump maven version from 3.9.14 to 3.9.16 by sychen · 4 weeks ago
  13. 17159eb [CELEBORN-2369] Retry stopped master Outbox failures by Chao Sun · 4 weeks ago
  14. 63e28ae [CELEBORN-2373] Support Flink 2.3 by Nicholas Jiang · 4 weeks ago
  15. 38f8231 [CELEBORN-2355] Return an empty stream from C++ ShuffleClientImpl::readPartition for an empty partition by Nicholas Jiang · 4 weeks ago
  16. a1ecf19 [CELEBORN-2372] Remove Hadoop 2 client support by Nicholas Jiang · 5 weeks ago
  17. 3820244 [CELEBORN-2368][FOLLOWUP] Remove leftover dependency list files for Spark 2.4 by sychen · 5 weeks ago
  18. a956fee [CELEBORN-2367][FOLLOWUP] Remove leftover dependency list files for Flink 1.16 and 1.17 by sychen · 5 weeks ago
  19. 581a0c0 [CELEBORN-2368] Remove Spark 2.4 client support by Nicholas Jiang · 5 weeks ago
  20. 5f49ed9 [CELEBORN-2367] Remove Flink 1.16 and 1.17 client support by Nicholas Jiang · 5 weeks ago
  21. 441d6b4 [CELEBORN-2354] Fix Helm chart indentation, PodMonitor flags and cluster-scoped PriorityClass namespace by Zemin Piao · 5 weeks ago
  22. 8903a31 [CELEBORN-2360] Fix ReviseLostShuffles RPC deserialization by afterincomparableyum · 5 weeks ago
  23. 0198bcf [CELEBORN-2334] Automatically restore RocksDB in case of failures by AmandeepSingh285 · 5 weeks ago
  24. d17489b [CELEBORN-2353] Align C++ shuffle client push/merge data path with Java ShuffleClient by Nicholas Jiang · 6 weeks ago
  25. 3a11d1e [CELEBORN-2365] Bump Spark version from 4.0.1 to 4.0.3 by Nicholas Jiang · 6 weeks ago
  26. 3eee443 [CELEBORN-2363] Bump Flink version to 1.20.5, 2.0.2 and 2.1.3 by Nicholas Jiang · 6 weeks ago
  27. 8c3108d [MINOR] Configure GitHub workflows to use concurrency cancel-in-progress for pull requests by Aurélien Pupier · 6 weeks ago
  28. 638270e [CELEBORN-2016] Fix the worker decommission and graceful shutdown condition by Sanskar Modi · 7 weeks ago
  29. 90b9b44 [CELEBORN-2351] Partition file sorting should only be paused for PUSH_AND_REPLICATE_PAUSED by Sanskar Modi · 7 weeks ago
  30. 61499a0 [CELEBORN-2319] Standalone LifecycleManager && rust sdk by 夷羿 · 7 weeks ago
  31. b1a7cb4 [CELEBORN-2315][FOLLOWUP] Change assertIteratorFullyConsumed to throw CelebornIOException by James Xu · 7 weeks ago
  32. 4a9112a [CELEBORN-2315] Add iterator fully-consumed validation after shuffle write by James Xu · 7 weeks ago
  33. b131a40 [MINOR] Fix PbSerDeUtilsTest failure by Sanskar Modi · 7 weeks ago
  34. e5099f9 [CELEBORN-2313] Extend E2E checked zone to batch assembly point by James Xu · 7 weeks ago
  35. a0f098f [CELEBORN-2347] Change get reducer file group cache to expireAfterAccess by Sanskar Modi · 7 weeks ago
  36. 93de9b3 [CELEBORN-2332] Fix self join deadlock in C++ WorkerPartitionReader fetch callbacks by afterincomparableyum · 7 weeks ago
  37. b105464 [CELEBORN-2348] Support end-to-end shuffle integrity check for Flink by Nicholas Jiang · 8 weeks ago
  38. bd2523f [CELEBORN-1577][FOLLOWUP] Fix backward compatiblity issue with interrupt shuffle by Sanskar Modi · 8 weeks ago
  39. bf0a1e8 [CELEBORN-2346] Add RequestSlots failure metrics by Chao Sun · 8 weeks ago
  40. 221129b [CELEBORN-2343] Fix timer leak in handlePushData by Sanskar Modi · 8 weeks ago
  41. c3bee9c [CELEBORN-2310][FOLLOWUP] Account actualUsableSpace while excluding workers by Sanskar Modi · 8 weeks ago
  42. c799373 [CELEBORN-2275][CIP-14] Add C++ merge-write and Java-read hybrid integration test by afterincomparableyum · 8 weeks ago
  43. 2497739 [CELEBORN-2342] Fix object aliasing in LegacySkewHandlingPartitionValidator corrupting sub-range metadata by James Xu · 8 weeks ago
  44. c546a21 [CELEBORN-2345] Fix allocation for rpcAskTimeout by Sanskar Modi · 8 weeks ago
  45. 2d5098b [CELEBORN-2339] Add tools.jar into classpath only for Java 8 by Cheng Pan · 9 weeks ago
  46. cf8d472 [CELEBORN-2338] Remove hardcoded CELEBORN_PRINT_LAUNCH_COMMAND=0 by Cheng Pan · 9 weeks ago
  47. dfe7def [CELEBORN-2337] Celeborn OpenAPI client should not shade slf4j-api by Cheng Pan · 9 weeks ago
  48. 759e7b5 [CELEBORN-2331] Parallelize batch open stream client creation by Chao Sun · 9 weeks ago
  49. 180db93 [CELEBORN-2326] Bump log4j-core version up to 2.25.4 by Yuriy Malygin · 9 weeks ago
  50. 1c807d9 [CELEBORN-2330] Fix HA master bootstrap redirect handling by Chao Sun · 9 weeks ago
  51. 91175ce [CELEBORN-2335] Bump Spark from 4.1.1 to 4.1.2 by SteNicholas · 9 weeks ago
  52. 671ef25 [CELEBORN-2328] Auto-apply correctness label from PR template checkbox by Fei Wang · 2 months ago
  53. 56444d2 [CELEBORN-2327] Add active-slot weight to load-aware placement by Chao Sun · 2 months ago
  54. 8b36b3d [CELEBORN-2333] Bump Flink from 2.2.0 to 2.2.1 by SteNicholas · 2 months ago
  55. f83350f [INFRA] Set up default rulesets for default and release branches by The Apache Software Foundation · 2 months ago
  56. ee7529f [CELEBORN-2310] Reject RESERVE_SLOTS when disks are full by Saurabh Dubey · 2 months ago
  57. 71a7d0a [CELEBORN-2257] Add reporting of remote disks during registration by Filip Darmanovic · 3 months ago
  58. 9ebbc6b [CELEBORN-2324] Fix JVMQuake threshold and JVMStat timer unit conversion by pithecuse527 · 3 months ago
  59. 50323e1 [CELEBORN-2316] Introduce metadata operation metrics by AmandeepSingh285 · 3 months ago
  60. e329b16 [CELEBORN-2253] Fix IndexOutOfBoundsException reading shuffle data from HDFS by 1fanwang · 3 months ago
  61. a70c8fd [CELEBORN-2306] Master adds shutdown hook for ratis stepdown by Kartikay Bhutani · 3 months ago
  62. 886e359 [CELEBORN-2314] Optimize the performance of DataBatches.requireBatches by afterincomparableyum · 3 months ago
  63. 7340428 [CELEBORN-2322] Upgrade version of docker/login-action for Login to Docker Hub by SteNicholas · 3 months ago
  64. 70ff956 [CELEBORN-2321] Avoid locking disk writers during memory split checks by Chao Sun · 3 months ago
  65. 8d473c5 [CELEBORN-2318] Miss increment to WRITE_DATA_HARD_SPLIT_COUNT on returning HARD_SPLIT in handlePushData by Kartikay Bhutani · 3 months ago
  66. fc08756 [CELEBORN-2320] Grafana dashboard linter should build from a checkout instead by SteNicholas · 3 months ago
  67. 69df893 [CELEBORN-2258][FOLLOWUP] Use IoHandlerFactories for EventLoopGroups to replace deprecated transport-specific event loop groups by SteNicholas · 3 months ago
  68. 59fd7a8 [CELEBORN-2309] Introduce JavaDeserializerFilter to support deserialization filter by SteNicholas · 3 months ago
  69. a56f69a [MINOR] Update DingTalk Contact Info by Shuang · 3 months ago
  70. 95419e1 [CELEBORN-2301] MessageEncoder enables zero-copy sendfile for FileRegion in Netty native transports by SteNicholas · 4 months ago
  71. 149f3b9 [CELEBORN-1577][BUG] Quota cancel shuffle should use app shuffle id by Sanskar Modi · 4 months ago
  72. c456df3 [CELEBORN-2298] Introduce NettyTransportBenchmark for Netty transport layer performance evaluation by SteNicholas · 4 months ago
  73. 913d027 [CELEBORN-2287] Split mode should be HARD_SPLIT when disk is full by zhengtao · 4 months ago
  74. 163bcb3 [CELEBORN-2297] Update workflow to manually install Helm and chart-testing by sychen · 4 months ago
  75. a30166d [CELEBORN-2305] Bump Ratis version from 3.2.1 to 3.2.2 by SteNicholas · 4 months ago
  76. c688c76 [CELEBORN-2063][FOLLOWUP] Fix timeout unit for parallel creation of partition writer by SteNicholas · 4 months ago
  77. c246031 [CELEBORN-2294][FOLLOWUP] Fix flaky test SparkUtilsSuite by Xianming Lei · 4 months ago
  78. 84830d9 [CELEBORN-2304] Fix timeout unit mismatch in disk monitor check by sychen · 4 months ago
  79. 7f1bac3 [CELEBORN-2302] Fix NPE in MemoryManager.close() when readBufferDispatcher is not initialized by sychen · 4 months ago
  80. 234ff2d [CELEBORN-2219][CIP-14] Support PushMergedData in CppClient by afterincomparableyum · 4 months ago
  81. ca8533c [CELEBORN-2300] Change the default value of celeborn.port.maxRetries from 1 to 16 by sychen · 4 months ago
  82. 37aed7e [CELEBORN-2295] CommitHandler should support retry interval by Xianming Lei · 4 months ago
  83. 37a27bc [CELEBORN-2296] Fix race condition in MemoryManager singleton initialization by sychen · 4 months ago
  84. 097f1df [CELEBORN-2294] The shuffle fetch failed report from the zombie stage should be ignored by Xianming Lei · 4 months ago
  85. c3adbca [CELEBORN-2293] Fix ConcurrentModificationException in WorkerStatusTracker.shuttingWorkers by Kartikay Bhutani · 4 months ago
  86. d3b7513 [CELEBORN-2292] Fix ArithmeticException when PUSH_DATA_HAND_SHAKE fails before any data written by luogen.lg · 4 months ago
  87. 42f1a08 [CELEBORN-2284] Fix TLS Memory Leak by Aravind Patnam · 4 months ago
  88. 235f07d [CELEBORN-2277] Replace synchronized in Flusher.getWorkerIndex with AtomicInteger by sychen · 4 months ago
  89. 6fc5565 [CELEBORN-2291] Support fsync on commit to ensure shuffle data durability by Kartikay Bhutani · 4 months ago
  90. 3773c65 [CELEBORN-2285] Bump maven 3.9.14 by sychen · 4 months ago
  91. 28a0733 [CELEBORN-2276] Fix race condition in MemoryManager.releaseSortMemory by sychen · 4 months ago
  92. 5fc0f19 [CELEBORN-2282] Eliminate redundant HashMap lookups in CelebornInputStream#fillBuffer by yew1eb · 4 months ago
  93. b4cb5a0 [CELEBORN-2283][BUG] Fix missing return in Master.handleRequestSlots when all workers are excluded by yew1eb · 4 months ago
  94. 7b25797 [CELEBORN-2274] Fix replicate channels not resumed when transitioning from PUSH_AND_REPLICATE_PAUSED to PUSH_PAUSED by Shuai Lu · 4 months ago
  95. 15cba46 [MINOR] Update repository references from incubator-gluten to gluten for TLP graduation of gluten by SteNicholas · 4 months ago
  96. af0ba1a [CELEBORN-2281] Improve error logging and null checks in CreditStreamManager by sychen · 4 months ago
  97. 400e951 [CELEBORN-2280] Support celeborn.network.memory.allocator.type to specify netty memory allocator by SteNicholas · 5 months ago
  98. 8c2c952 [CELEBORN-2279] Update log level from `INFO` to `ERROR` for console output in spark-it tests by sychen · 5 months ago
  99. 4b157c6 [CELEBORN-2278] Make HTTP auth bypass API paths configurable by Aravind Patnam · 5 months ago
  100. b78177f [CELEBORN-2238] Fix RuntimeException during stream cleanup preventing peer failover by Shuai Lu · 5 months ago