issues  

Messages by Thread

• [PR] fix(spark): Increment segmentIndex when skipping segment due to crc check failure [uniffle] via GitHub
  • Re: [PR] fix(spark): Increment segmentIndex when skipping segment due to crc check failure [uniffle] via GitHub
  • Re: [PR] fix(spark): Increment segmentIndex when skipping segment due to crc check failure [uniffle] via GitHub
  • Re: [PR] fix(spark): Increment segmentIndex when skipping segment due to crc check failure [uniffle] via GitHub
• [PR] fix(spark): potential hang with skipped segments on overlapping decompression [uniffle] via GitHub
  • Re: [PR] fix(spark): potential hang with skipped segments on overlapping decompression [uniffle] via GitHub
  • Re: [PR] fix(spark): potential hang with skipped segments on overlapping decompression [uniffle] via GitHub
  • Re: [PR] fix(spark): potential hang with skipped segments on overlapping decompression [uniffle] via GitHub
  • Re: [PR] fix(spark): potential hang with skipped segments on overlapping decompression [uniffle] via GitHub
  • Re: [PR] fix(spark): potential hang with skipped segments on overlapping decompression [uniffle] via GitHub
  • Re: [PR] fix(spark): potential hang with skipped segments on overlapping decompression [uniffle] via GitHub
• [PR] [#2739] feat(server): Trigger flush when there are too many blocks in shuffle buffer [uniffle] via GitHub
  • Re: [PR] [#2739] feat(server): Trigger flush when there are too many blocks in shuffle buffer [uniffle] via GitHub
  • Re: [PR] [#2739] feat(server): Trigger flush when there are too many blocks in shuffle buffer [uniffle] via GitHub
  • Re: [PR] [#2739] feat(server): Trigger flush when there are too many blocks in shuffle buffer [uniffle] via GitHub
  • Re: [PR] [#2739] feat(server): Trigger flush when there are too many blocks in shuffle buffer [uniffle] via GitHub
  • Re: [PR] [#2739] feat(server): Trigger flush when there are too many blocks in shuffle buffer [uniffle] via GitHub
• [I] [Flaky Test] org.apache.uniffle.client.impl.DecompressionWorkerTest#testBackpressure [uniffle] via GitHub
  • Re: [I] [Flaky Test] org.apache.uniffle.client.impl.DecompressionWorkerTest#testBackpressure [uniffle] via GitHub
  • Re: [I] [Flaky Test] org.apache.uniffle.client.impl.DecompressionWorkerTest#testBackpressure [uniffle] via GitHub
  • Re: [I] [Flaky Test] org.apache.uniffle.client.impl.DecompressionWorkerTest#testBackpressure [uniffle] via GitHub
• [PR] [#2740] improvement(server) Just check block count while checking commit result [uniffle] via GitHub
  • Re: [PR] [#2740] improvement(server) Just check block count while checking commit result [uniffle] via GitHub
  • Re: [PR] [#2740] improvement(server) Just check block count while checking commit result [uniffle] via GitHub
  • Re: [PR] [#2740] improvement(server) Just check block count while checking commit result [uniffle] via GitHub
  • Re: [PR] [#2740] improvement(server) Just check block count while checking commit result [uniffle] via GitHub
  • Re: [PR] [#2740] improvement(server) Just check block count while checking commit result [uniffle] via GitHub
  • Re: [PR] [#2740] improvement(server) Just check block count while checking commit result [uniffle] via GitHub
  • Re: [PR] [#2740] improvement(server) Just check block count while checking commit result [uniffle] via GitHub
  • Re: [PR] [#2740] improvement(server) Just check block count while checking commit result [uniffle] via GitHub
  • Re: [PR] [#2740] improvement(server) Just check block count while checking commit result [uniffle] via GitHub
  • Re: [PR] [#2740] improvement(server) Just check block count while checking commit result [uniffle] via GitHub
  • Re: [PR] [#2740] improvement(server) Just check block count while checking commit result [uniffle] via GitHub
• [PR] [#2738] feat(server): add metrics to track shuffle data block count and avg block size [uniffle] via GitHub
  • Re: [PR] [#2738] feat(server): add metrics to track shuffle data block count and avg block size [uniffle] via GitHub
  • Re: [PR] [#2738] feat(server): add metrics to track shuffle data block count and avg block size [uniffle] via GitHub
  • Re: [PR] [#2738] feat(server): add metrics to track shuffle data block count and avg block size [uniffle] via GitHub
• [I] [Improvement] Too many blocks in a single task for partition can cause a memory overflow [uniffle] via GitHub
  • Re: [I] [Improvement] Too many blocks generated by a single task for a partition can cause memory overflow [uniffle] via GitHub
• [I] [FEATURE] Trigger flush when there are too many blocks in shuffle buffer [uniffle] via GitHub
  • Re: [I] [FEATURE] Trigger flush when there are too many blocks in shuffle buffer [uniffle] via GitHub
• [I] [FEATURE] Add metrics to track shuffle data block count and avg block size [uniffle] via GitHub
  • Re: [I] [FEATURE] Add metrics to track shuffle data block count and avg block size [uniffle] via GitHub
• [PR] [#2601][FOLLOWUP] fix(spark): Release segmentPermits first to avoid deadlock [uniffle] via GitHub
  • Re: [PR] [#2601][FOLLOWUP] fix(spark): Release segmentPermits first to avoid deadlock [uniffle] via GitHub
  • Re: [PR] [#2601][FOLLOWUP] fix(spark): Release segmentPermits first to avoid deadlock [uniffle] via GitHub
  • Re: [PR] [#2601][FOLLOWUP] fix(spark): Release segmentPermits first to avoid deadlock [uniffle] via GitHub
  • Re: [PR] [#2601][FOLLOWUP] fix(spark): Release segmentPermits first to avoid deadlock [uniffle] via GitHub
• [PR] fix(spark): Correct shuffle read time metrics [uniffle] via GitHub
  • Re: [PR] fix(spark): Correct shuffle read time metrics [uniffle] via GitHub
  • Re: [PR] fix(spark): Correct shuffle read time metrics [uniffle] via GitHub
  • Re: [PR] fix(spark): Correct shuffle read time metrics [uniffle] via GitHub
  • Re: [PR] fix(spark): Correct shuffle read time metrics [uniffle] via GitHub
• [PR] [#2716] feat(spark): Introduce option of max segments decompression to control memory usage [uniffle] via GitHub
  • Re: [PR] [#2716] feat(spark): Introduce option of max segments decompression to control memory usage [uniffle] via GitHub
  • Re: [PR] [#2716] feat(spark): Introduce option of max segments decompression to control memory usage [uniffle] via GitHub
  • Re: [PR] [#2716] feat(spark): Introduce option of max segments decompression to control memory usage [uniffle] via GitHub
  • Re: [PR] [#2716] feat(spark): Introduce option of max segments decompression to control memory usage [uniffle] via GitHub
  • Re: [PR] [#2716] feat(spark): Introduce option of max segments decompression to control memory usage [uniffle] via GitHub
  • Re: [PR] [#2716] feat(spark): Introduce option of max segments decompression to control memory usage [uniffle] via GitHub
  • Re: [PR] [#2716] feat(spark): Introduce option of max segments decompression to control memory usage [uniffle] via GitHub
  • Re: [PR] [#2716] feat(spark): Introduce option of max segments decompression to control memory usage [uniffle] via GitHub
  • Re: [PR] [#2716] feat(spark): Introduce option of max segments decompression to control memory usage [uniffle] via GitHub
  • Re: [PR] [#2716] feat(spark): Introduce option of max segments decompression to control memory usage [uniffle] via GitHub
  • Re: [PR] [#2716] feat(spark): Introduce option of max segments decompression to control memory usage [uniffle] via GitHub
• Re: [I] [Bug] The total shuffle read time in uniffle ui is zero [uniffle] via GitHub
• Re: [PR] [#2733] fix(spark): Calculate total value for ShuffleReadTimesSummary [uniffle] via GitHub
• [PR] [#2646] feat(netty): Support converting CompositeByteBuf to a direct nio buffer [uniffle] via GitHub
  • Re: [PR] [#2646] feat(netty): Support converting CompositeByteBuf to a direct nio buffer [uniffle] via GitHub
  • Re: [PR] [#2646] feat(netty): Support converting CompositeByteBuf to a direct nio buffer [uniffle] via GitHub
  • Re: [PR] [#2646] feat(netty): Support converting CompositeByteBuf to a direct nio buffer [uniffle] via GitHub
• [PR] [#2730] improvement(common): Move CompositeFileRegion class and do nothing in deallocate method [uniffle] via GitHub
  • Re: [PR] [#2730] improvement(common): Move CompositeFileRegion class and do nothing in deallocate method [uniffle] via GitHub
  • Re: [PR] [#2730] improvement(common): Move CompositeFileRegion class and do nothing in deallocate method [uniffle] via GitHub
  • Re: [PR] [#2730] improvement(common): Move CompositeFileRegion class and do nothing in deallocate method [uniffle] via GitHub
  • Re: [PR] [#2730] improvement(common): Move CompositeFileRegion class and do nothing in deallocate method [uniffle] via GitHub
  • Re: [PR] [#2730] improvement(common): Move CompositeFileRegion class and do nothing in deallocate method [uniffle] via GitHub
• [I] [Improvement] Move CompositeFileRegion class to uniffle package [uniffle] via GitHub
  • Re: [I] [Improvement] Move CompositeFileRegion class to uniffle package [uniffle] via GitHub
• [PR] [#2725] fix(spark)(partition-split): Fallback under load-balance mode and fix stale assignment missing callback to cause timeout [uniffle] via GitHub
  • Re: [PR] [#2725] fix(spark)(partition-split): Add fallback under load-balance mode and fix stale assignment missing callback that caused timeout [uniffle] via GitHub
  • Re: [PR] [#2725] fix(spark)(partition-split): Add fallback under load-balance mode and fix stale assignment missing callback that caused timeout [uniffle] via GitHub
  • Re: [PR] [#2725] fix(spark)(partition-split): Add fallback under load-balance mode and fix stale assignment missing callback that caused timeout [uniffle] via GitHub
  • Re: [PR] [#2725] fix(spark)(partition-split): Add fallback under load-balance mode and fix stale assignment missing callback that caused timeout [uniffle] via GitHub
  • Re: [PR] [#2725] fix(spark)(partition-split): Add fallback under load-balance mode and fix stale assignment missing callback that caused timeout [uniffle] via GitHub
  • Re: [PR] [#2725] fix(spark)(partition-split): Add fallback under load-balance mode and fix stale assignment missing callback that caused timeout [uniffle] via GitHub
  • Re: [PR] [#2725] fix(spark)(partition-split): Add fallback under load-balance mode and fix stale assignment missing callback that caused timeout [uniffle] via GitHub
  • Re: [PR] [#2725] fix(spark)(partition-split): Add fallback under load-balance mode and fix stale assignment missing callback that caused timeout [uniffle] via GitHub
• [PR] chore(spark): Remove logs of successful heartbeat [uniffle] via GitHub
  • Re: [PR] chore(spark): Remove logs of successful heartbeat [uniffle] via GitHub
  • Re: [PR] chore(spark): Remove logs of successful heartbeat [uniffle] via GitHub
• [PR] [#2724] refactor(spark): Introduce `ReassignExecutor` to clarify shuffle writer logic [uniffle] via GitHub
  • Re: [PR] [#2724] refactor(spark): Introduce `ReassignExecutor` to clarify shuffle writer logic [uniffle] via GitHub
  • Re: [PR] [#2724] refactor(spark): Introduce `ReassignExecutor` to simplify shuffle writer logic [uniffle] via GitHub
  • Re: [PR] [#2724] refactor(spark): Introduce `ReassignExecutor` to simplify shuffle writer logic [uniffle] via GitHub
• [PR] [#2725] feat(spark): Introduce optional fast-switch and ignore retry-count checking for stale assignment [uniffle] via GitHub
  • Re: [PR] [#2725] feat(spark): Introduce optional fast-switch and ignore retry-count checking for stale assignment [uniffle] via GitHub
  • Re: [PR] [#2725] feat(spark): Introduce optional fast-switch and ignore retry-count checking for stale assignment [uniffle] via GitHub
  • Re: [PR] [#2725] feat(spark): Introduce optional fast-switch and ignore retry-count checking for stale assignment [uniffle] via GitHub
  • Re: [PR] [#2725] feat(spark): Introduce optional fast-switch and ignore retry-count checking for stale assignment [uniffle] via GitHub
  • Re: [PR] [#2725] feat(spark): Introduce optional fast-switch and ignore retry-count checking for stale assignment [uniffle] via GitHub
  • Re: [PR] [#2725] feat(spark): Introduce optional fast-switch and ignore retry-count checking for stale assignment [uniffle] via GitHub
  • Re: [PR] [#2725] feat(spark): Introduce optional fast-switch and ignore retry-count checking for stale assignment [uniffle] via GitHub
  • Re: [PR] [#2725] feat(spark): Introduce optional fast-switch and ignore retry-count checking for stale assignment [uniffle] via GitHub
  • Re: [PR] [#2725] feat(spark): Introduce optional fast-switch and ignore retry-count checking for stale assignment [uniffle] via GitHub
  • Re: [PR] [#2725] feat(spark): Introduce optional fast-switch and ignore retry-count checking for stale assignment [uniffle] via GitHub
• [I] [Bug] Block send failed in partition-split mode due to retry time exceeded [uniffle] via GitHub
  • Re: [I] [Bug] Block send failed in partition-split mode due to retry time exceeded [uniffle] via GitHub
• [I] [FEATURE] Refactor the reassign part code in spark3 client [uniffle] via GitHub
  • Re: [I] [FEATURE] Refactor the reassign part code in spark3 client [uniffle] via GitHub
• [PR] [#2722] feat(operator): Upgrade to golang 1.25 [uniffle] via GitHub
  • Re: [PR] [#2722] feat(operator): Upgrade to golang 1.25 [uniffle] via GitHub
  • Re: [PR] [#2722] feat(operator): Upgrade to golang 1.25 [uniffle] via GitHub
• Re: [I] [Improvement] better operation support for RSS operator [uniffle] via GitHub
• [I] [Bug] I cannot build Uniffle operator with Go with version later than 1.19 [uniffle] via GitHub
  • Re: [I] [Bug] I cannot build Uniffle operator with Go with version later than 1.19 [uniffle] via GitHub
• [I] [Improvement] Fine-grained lock for MutableShuffleHandle when reassign happens [uniffle] via GitHub
• [PR] [#2718] feat(spark): Reduce memory-copy by `CompositeByteBuf` in `WriterBuffer` [uniffle] via GitHub
  • Re: [PR] [#2718] feat(spark): Reduce memory-copy by `CompositeByteBuf` in `WriterBuffer` [uniffle] via GitHub
  • Re: [PR] [#2718] feat(spark): Eliminate copy in WriterBuffer when compression off for Gluten [uniffle] via GitHub
  • Re: [PR] [#2718] feat(spark): Eliminate copy in WriterBuffer when compression off for Gluten [uniffle] via GitHub
  • Re: [PR] [#2718] feat(spark): Eliminate copy in WriterBuffer when compression off for Gluten [uniffle] via GitHub
  • Re: [PR] [#2718] feat(spark): Eliminate copy in WriterBuffer when compression off for Gluten [uniffle] via GitHub
  • Re: [PR] [#2718] feat(spark): Eliminate copy in WriterBuffer when compression off for Gluten [uniffle] via GitHub
  • Re: [PR] [#2718] feat(spark): Eliminate copy in WriterBuffer when compression off for Gluten [uniffle] via GitHub
  • Re: [PR] [#2718] feat(spark): Eliminate copy in WriterBuffer when compression off for Gluten [uniffle] via GitHub
  • Re: [PR] [#2718] feat(spark): Eliminate copy in WriterBuffer when compression off for Gluten [uniffle] via GitHub
  • Re: [PR] [#2718] feat(spark): Eliminate copy in WriterBuffer when compression off for Gluten [uniffle] via GitHub
  • Re: [PR] [#2718] feat(spark): Eliminate copy in WriterBuffer when compression off for Gluten [uniffle] via GitHub
  • Re: [PR] [#2718] feat(spark): Eliminate copy in WriterBuffer when compression off for Gluten [uniffle] via GitHub
  • Re: [PR] [#2718] feat(spark): Eliminate copy in WriterBuffer when compression off for Gluten [uniffle] via GitHub
  • Re: [PR] [#2718] feat(spark): Eliminate copy in WriterBuffer when compression off for Gluten [uniffle] via GitHub
• [I] [Bug] Invalid purge of cached shuffle handle information in Spark [uniffle] via GitHub
• [I] [FEATURE] Reduce memory footprint for gluten on createShuffleBlock [uniffle] via GitHub
  • Re: [I] [FEATURE] Reduce memory footprint for gluten on createShuffleBlock [uniffle] via GitHub
• [PR] [#2716] feat(client): More decompression stats to log [uniffle] via GitHub
  • Re: [PR] [#2716] feat(client): More decompression stats to log [uniffle] via GitHub
  • Re: [PR] [#2716] feat(client): More overlapping decompression stats to log [uniffle] via GitHub
• [I] [FEATURE] Better memory limitation when overlapping decompression is enabled [uniffle] via GitHub
  • Re: [I] [FEATURE] Better memory limitation when overlapping decompression is enabled [uniffle] via GitHub
  • Re: [I] [FEATURE] Better memory limitation when overlapping decompression is enabled [uniffle] via GitHub
  • Re: [I] [FEATURE] Better memory limitation when overlapping decompression is enabled [uniffle] via GitHub
  • Re: [I] [FEATURE] Better memory limitation when overlapping decompression is enabled [uniffle] via GitHub
• [PR] [#2714] feat(spark): Respect compression type when activating overlapping compression mechanism [uniffle] via GitHub
  • Re: [PR] [#2714] feat(spark): Respect compression type when activating overlapping compression mechanism [uniffle] via GitHub
  • Re: [PR] [#2714] feat(spark): Respect compression type when activating overlapping compression mechanism [uniffle] via GitHub
  • Re: [PR] [#2714] feat(spark): Respect compression type when activating overlapping compression mechanism [uniffle] via GitHub
  • Re: [PR] [#2714] feat(spark): Respect compression type when activating overlapping compression mechanism [uniffle] via GitHub
  • Re: [PR] [#2714] feat(spark): Respect compression type when activating overlapping compression mechanism [uniffle] via GitHub
  • Re: [PR] [#2714] feat(spark): Respect compression type when activating overlapping compression mechanism [uniffle] via GitHub
• [I] [Bug] Jvm OOM caused by RSS Writer OverlappingCompression [uniffle] via GitHub
  • Re: [I] [Bug] Jvm OOM caused by RSS Writer OverlappingCompression [uniffle] via GitHub
  • Re: [I] [Bug] Jvm OOM caused by RSS Writer OverlappingCompression [uniffle] via GitHub
• [PR] feat(doc): Update spark related performance guide in doc [uniffle] via GitHub
  • Re: [PR] feat(doc): Update spark related performance guide in doc [uniffle] via GitHub
  • Re: [PR] feat(doc): Update spark related performance guide in doc [uniffle] via GitHub
  • Re: [PR] feat(doc): Update spark related performance guide in doc [uniffle] via GitHub
• [PR] [#2711] fix(spark): Race condition on deferred compressed block initialization [uniffle] via GitHub
  • Re: [PR] [#2711] fix(spark): Race condition on deferred compressed block initialization [uniffle] via GitHub
  • Re: [PR] [#2711] fix(spark): Race condition on deferred compressed block initialization [uniffle] via GitHub
  • Re: [PR] [#2711] fix(spark): Race condition on deferred compressed block initialization [uniffle] via GitHub
  • Re: [PR] [#2711] fix(spark): Race condition on deferred compressed block initialization [uniffle] via GitHub
  • Re: [PR] [#2711] fix(spark): Race condition on deferred compressed block initialization [uniffle] via GitHub
  • Re: [PR] [#2711] fix(spark): Race condition on deferred compressed block initialization [uniffle] via GitHub
  • Re: [PR] [#2711] fix(spark): Race condition on deferred compressed block initialization [uniffle] via GitHub
  • Re: [PR] [#2711] fix(spark): Race condition on deferred compressed block initialization [uniffle] via GitHub
  • Re: [PR] [#2711] fix(spark): Race condition on deferred compressed block initialization [uniffle] via GitHub
• [I] [Flaky Test] org.apache.uniffle.test.GetShuffleReportForMultiPartTest [uniffle] via GitHub
  • Re: [I] [Flaky Test] org.apache.uniffle.test.GetShuffleReportForMultiPartTest [uniffle] via GitHub
  • Re: [I] [Flaky Test] org.apache.uniffle.test.GetShuffleReportForMultiPartTest [uniffle] via GitHub
  • Re: [I] [Flaky Test] org.apache.uniffle.test.GetShuffleReportForMultiPartTest [uniffle] via GitHub
• [PR] [#2709] fix(spark): Fix serialization error in Spark History UI [uniffle] via GitHub
  • Re: [PR] [#2709] fix(spark): Fix serialization error in Spark History UI [uniffle] via GitHub
  • Re: [PR] [#2709] fix(spark): Fix serialization error in Spark History UI [uniffle] via GitHub
  • Re: [PR] [#2709] fix(spark): Fix serialization error in Spark History UI [uniffle] via GitHub
  • Re: [PR] [#2709] fix(spark): Fix serialization error in Spark History UI [uniffle] via GitHub
  • Re: [PR] [#2709] fix(spark): Fix serialization error in Spark History UI [uniffle] via GitHub
  • Re: [PR] [#2709] fix(spark): Fix serialization error in Spark History UI [uniffle] via GitHub
  • Re: [PR] [#2709] fix(spark): Fix serialization error in Spark History UI [uniffle] via GitHub
• [I] [Bug] [uniffle] via GitHub
  • Re: [I] [Bug] Some entities of spark uniffle ui cannot be deserialized in history server hybridStore [uniffle] via GitHub
• [PR] [#2707] fix(server): Wrap calcTopNShuffleDataSize in error handling [uniffle] via GitHub
  • Re: [PR] [#2707] fix(server): Wrap calcTopNShuffleDataSize in error handling [uniffle] via GitHub
  • Re: [PR] [#2707] fix(server): Wrap calcTopNShuffleDataSize in error handling [uniffle] via GitHub
  • Re: [PR] [#2707] fix(server): Wrap calcTopNShuffleDataSize in error handling [uniffle] via GitHub
  • Re: [PR] [#2707] fix(server): Wrap calcTopNShuffleDataSize in error handling [uniffle] via GitHub
• [I] [Bug] The `topN_of_total_data_size_for_app` metric stops updating permanently [uniffle] via GitHub
  • Re: [I] [Bug] The `topN_of_total_data_size_for_app` metric stops updating permanently [uniffle] via GitHub
• [PR] [#2705] fix: Add read-write lock for MutableShuffleHandleInfo to avoid global locking [uniffle] via GitHub
  • Re: [PR] [#2705] fix: Add read-write lock for MutableShuffleHandleInfo to avoid global locking [uniffle] via GitHub
  • Re: [PR] [#2705] fix(spark): Use read-write lock for `MutableShuffleHandleInfo` to avoid global locking [uniffle] via GitHub
• [I] [Bug] `MutableShuffleHandleInfo#toProto` synchronization lock caused `getShuffleHandleInfo` to time out. [uniffle] via GitHub
  • Re: [I] [Bug] `MutableShuffleHandleInfo#toProto` synchronization lock caused `getShuffleHandleInfo` to time out. [uniffle] via GitHub
• [PR] [#2700] feat(spark): Eager shuffle deletion [uniffle] via GitHub
  • Re: [PR] [#2700] feat(spark): Eager shuffle deletion [uniffle] via GitHub
  • Re: [PR] [#2700] feat(spark): Eager shuffle deletion [uniffle] via GitHub
  • Re: [PR] [#2700] feat(spark): Eager shuffle deletion [uniffle] via GitHub
  • Re: [PR] [#2700] feat(spark): Eager shuffle deletion [uniffle] via GitHub
  • Re: [PR] [#2700] feat(spark): Eager shuffle deletion [uniffle] via GitHub
  • Re: [PR] [#2700] feat(spark): Eager shuffle deletion [uniffle] via GitHub

• Earlier messages