issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2025/08/11
Re: [PR] [CELEBORN-2096]Support Lz4 Compression in CppClient [celeborn]
via GitHub
2025/08/11
[PR] [CELEBORN-2096]Support Lz4 Compression in CppClient [celeborn]
via GitHub
2025/08/11
Re: [PR] [WIP] Dynamically adjust partition write parallelism [celeborn]
via GitHub
2025/08/11
Re: [PR] [CIP-19][CELEBORN-1939] CongestionController should not limit user push speed when worker load is low [celeborn]
via GitHub
2025/08/11
Re: [PR] [CELEBORN-2032] Create reader should change to peer by taskAttemptId [celeborn]
via GitHub
2025/08/11
Re: [PR] [CELEBORN-2060] Refactor `SlotsAlloctor` for better scalability [celeborn]
via GitHub
2025/08/11
Re: [PR] [CELEBORN-2066] Release workers only with high workload when the number of excluded worker set is too large. [celeborn]
via GitHub
2025/08/11
Re: [PR] [CELEBORN-2074] Create hdfs shuffle directory by master to reduce Namenode call [celeborn]
via GitHub
2025/08/11
Re: [PR] [CELEBORN-2091]Support Zstd Decompression in CppClient [celeborn]
via GitHub
2025/08/11
Re: [PR] [CELEBORN-2095][CIP-14] Support RegisterShuffle/Response in cppClient [celeborn]
via GitHub
2025/08/11
Re: [PR] [CELEBORN-2095][CIP-14] Support RegisterShuffle/Response in cppClient [celeborn]
via GitHub
2025/08/11
Re: [PR] [CELEBORN-2095][CIP-14] Support RegisterShuffle/Response in cppClient [celeborn]
via GitHub
2025/08/11
Re: [PR] [CELEBORN-2095][CIP-14] Support RegisterShuffle/Response in cppClient [celeborn]
via GitHub
2025/08/10
Re: [PR] [CELEBORN-2091]Support Zstd Decompression in CppClient [celeborn]
via GitHub
2025/08/10
[PR] [CELEBORN-2091]Support Zstd Decompression in CppClient [celeborn]
via GitHub
2025/08/10
Re: [PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/08/09
Re: [PR] [CELEBORN-1971] Use synchronization as opposed to Thread.sleep for InFlightRequestTracker limit [celeborn]
via GitHub
2025/08/08
Re: [PR] [CELEBORN-2090] Support Lz4 Decompression in CppClient [celeborn]
via GitHub
2025/08/08
Re: [PR] [CELEBORN-2095][CIP-14] Support RegisterShuffle/Response in cppClient [celeborn]
via GitHub
2025/08/08
[PR] [CELEBORN-2095][CIP-14] Support RegisterShuffle/Response in cppClient [celeborn]
via GitHub
2025/08/07
Re: [PR] [CELEBORN-2085] Use a fixed buffer for flush copying to reduce GC [celeborn]
via GitHub
2025/08/07
Re: [PR] [CELEBORN-2085] Use a fixed buffer for flush copying to reduce GC [celeborn]
via GitHub
2025/08/07
Re: [PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/08/07
Re: [PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/08/07
Re: [PR] Adjust `celeborn.client.push.slowStart.initialSleepTime` default value from `500ms` to `0` [celeborn]
via GitHub
2025/08/07
[PR] Adjust `celeborn.client.push.slowStart.initialSleepTime` default value from `500ms` to `0` [celeborn]
via GitHub
2025/08/06
Re: [PR] [CELEBORN-1971] Use synchronization as opposed to Thread.sleep for InFlightRequestTracker limit [celeborn]
via GitHub
2025/08/06
Re: [PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/08/05
Re: [PR] [CELEBORN-1844][FOLLOWUP] Fix the condition of StoragePolicy that worker uses memory storage [celeborn]
via GitHub
2025/08/05
Re: [PR] [CELEBORN-1844][FOLLOWUP] Fix the condition of StoragePolicy that worker uses memory storage [celeborn]
via GitHub
2025/08/05
[PR] [CELEBORN-1844][FOLLOWUP] Fix the condition of StoragePolicy that worker uses memory storage [celeborn]
via GitHub
2025/08/05
Re: [PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/08/05
Re: [PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/08/05
Re: [PR] [CELEBORN-1792][FOLLOWUP] Add missing break in resumeByPinnedMemory [celeborn]
via GitHub
2025/08/05
Re: [PR] [CELEBORN-1792][FOLLOWUP] Add missing break in resumeByPinnedMemory [celeborn]
via GitHub
2025/08/03
Re: [PR] [CELEBORN-2090] Support Lz4 Decompression in CppClient [celeborn]
via GitHub
2025/08/03
[PR] [CELEBORN-1792][FOLLOWUP] Add missing break in resumeByPinnedMemory [celeborn]
via GitHub
2025/08/03
Re: [PR] [CELEBORN-2093] Support Flink 2.1 [celeborn]
via GitHub
2025/08/03
Re: [PR] [CELEBORN-2093] Support Flink 2.1 [celeborn]
via GitHub
2025/08/03
Re: [PR] [CELEBORN-2090] Support Lz4 Decompression in CppClient [celeborn]
via GitHub
2025/08/03
Re: [PR] [CELEBORN-2090] Support Lz4 Decompression in CppClient [celeborn]
via GitHub
2025/08/03
Re: [PR] [CELEBORN-2090] Support Lz4 Decompression in CppClient [celeborn]
via GitHub
2025/08/03
Re: [PR] [CELEBORN-2058] Add retry to avoid commtting failed with HDFS storage [celeborn]
via GitHub
2025/08/01
Re: [PR] [CELEBORN-2064] Fix the issue where reading replica partition that returns zero chunk causes tasks to hang [celeborn]
via GitHub
2025/08/01
Re: [PR] [CELEBORN-2064] Fix the issue where reading replica partition that returns zero chunk causes tasks to hang [celeborn]
via GitHub
2025/08/01
Re: [PR] [CELEBORN-1984] Merge ResourceRequest to transportMessageProtobuf [celeborn]
via GitHub
2025/08/01
Re: [PR] [CELEBORN-1984] Merge ResourceRequest to transportMessageProtobuf [celeborn]
via GitHub
2025/08/01
Re: [PR] [CELEBORN-2090] Support Lz4 Decompression in CppClient [celeborn]
via GitHub
2025/08/01
Re: [PR] [CELEBORN-2064] Fix the issue where reading replica partition that returns zero chunk causes tasks to hang [celeborn]
via GitHub
2025/08/01
Re: [PR] [CELEBORN-2044] Proactively cleanup stream state from ChunkStreamManager when the stream ends [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2044] Proactively cleanup stream state from ChunkStreamManager when the stream ends [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2094] Add WorkerProduceSpeed for worker congestion control [celeborn]
via GitHub
2025/07/31
Re: [PR] log [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2094] Add WorkerProduceSpeed for worker congestion control [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2094] Add WorkerProduceSpeed for worker congestion control [celeborn]
via GitHub
2025/07/31
[PR] Worker produce speed [celeborn]
via GitHub
2025/07/31
[PR] log [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2088] Fix NPE if `celeborn.client.spark.fetch.cleanFailedShuffle` enabled [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2088] Fix NPE if `celeborn.client.spark.fetch.cleanFailedShuffle` enabled [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2092] Inc COMMIT_FILES_FAIL_COUNT when TimerWriter::close timeout [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2092] Inc COMMIT_FILES_FAIL_COUNT when TimerWriter::close timeout [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2085] Use a fixed buffer for flush copying to reduce GC [celeborn]
via GitHub
2025/07/31
[PR] [CELEBORN-2093] Support Flink 2.1 [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2090] Support Lz4 Decompression in CppClient [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2090] Support Lz4 Decompression in CppClient [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2090] Support Lz4 Decompression in CppClient [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2090] Support Lz4 Decompression in CppClient [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2090] Support Lz4 Decompression in CppClient [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2090] Support Lz4 Decompression in CppClient [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2024][FOLLOWUP] Increase COMMIT_FILES_FAIL_COUNT when closing tier writer timeout [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2024][FOLLOWUP] Increase COMMIT_FILES_FAIL_COUNT when closing tier writer timeout [celeborn]
via GitHub
2025/07/31
Re: [PR] Commit failed [celeborn]
via GitHub
2025/07/31
Re: [PR] Commit failed [celeborn]
via GitHub
2025/07/31
[PR] Commit failed [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2090] Support Lz4 Decompression in CppClient [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2085] Use a fixed buffer for flush copying to reduce GC [celeborn]
via GitHub
2025/07/31
Re: [PR] [CELEBORN-2085] Use a fixed buffer for flush copying to reduce GC [celeborn]
via GitHub
2025/07/31
[PR] [CELEBORN-2090] Support Lz4 Decompression in CppClient [celeborn]
via GitHub
2025/07/30
Re: [PR] [CELEBORN-2088] Fix NPE if `celeborn.client.spark.fetch.cleanFailedShuffle` enabled [celeborn]
via GitHub
2025/07/30
Re: [PR] [CELEBORN-2088] Fix NPE if `celeborn.client.spark.fetch.cleanFailedShuffle` enabled [celeborn]
via GitHub
2025/07/30
[PR] Fix npe [celeborn]
via GitHub
2025/07/30
Re: [D] Not Seeing Speedup with Celeborn [celeborn]
via GitHub
2025/07/30
Re: [D] Not Seeing Speedup with Celeborn [celeborn]
via GitHub
2025/07/30
Re: [D] Not Seeing Speedup with Celeborn [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-2085] Use a fixed buffer for flush copying to reduce GC [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-2070][CIP-14] Support MapperEnd/Response in CppClient [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-2070][CIP-14] Support MapperEnd/Response in CppClient [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-2085] Use a fixed buffer for flush copying to reduce GC [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-2087] Refine the docs configuration table view [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-2087] Refine the docs configuration table view [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-2087] Refine the docs configuration table view [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-2085] Use a fixed buffer for flush copying to reduce GC [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-2087] Refine the docs configuration table view [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-2087] Refine the docs configuration view [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-2087] Refine the docs configuration view [celeborn]
via GitHub
2025/07/29
[PR] Celeborn config [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-1971] Use synchronization as opposed to Thread.sleep for InFlightRequestTracker limit [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-1971] Use synchronization as opposed to Thread.sleep for InFlightRequestTracker limit [celeborn]
via GitHub
2025/07/29
Re: [PR] Set max memory of SortBasedPusher based off Spark configs [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-1768][SPARK-3][WRITER] Refactoring Shuffle Writer to extract common methods [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-1841][FOLLOWUP] Support custom implementation of EventExecutorChooser to avoid deadlock when calling await in EventLoop thread for EpollEventLoopGroup [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-2049] Bump Ratis version from 3.1.3 to 3.2.0 [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-2086] S3FlushTask and OssFlushTask should close ByteArrayInputStream to avoid resource leak [celeborn]
via GitHub
2025/07/29
Re: [PR] [CELEBORN-2086] S3FlushTask and OssFlushTask should close ByteArrayInputStream to avoid resource leak [celeborn]
via GitHub
2025/07/28
Re: [PR] [MINOR] Document introduced metrics into monitoring.md [celeborn]
via GitHub
2025/07/28
Re: [PR] [MINOR] Document introduced metrics into monitoring.md [celeborn]
via GitHub
2025/07/28
Re: [PR] [CELEBORN-2085] Use a fixed buffer for flush copying to reduce GC [celeborn]
via GitHub
2025/07/28
Re: [PR] [CELEBORN-2086] S3FlushTask and OssFlushTask should close ByteArrayInputStream to avoid resource leak [celeborn]
via GitHub
2025/07/28
[PR] [MINOR] Document introduced metrics into monitoring.md [celeborn]
via GitHub
2025/07/28
Re: [PR] [CELEBORN-1971] Use synchronization as opposed to Thread.sleep for InFlightRequestTracker limit [celeborn]
via GitHub
2025/07/28
[PR] [CELEBORN-1971] Use synchronization as opposed to Thread.sleep for InFlightRequestTracker limit [celeborn]
via GitHub
2025/07/28
Re: [PR] [CELEBORN-894][CELEBORN-474][FOLLOWUP] PushState uses JavaUtils#newConcurrentHashMap to speed up ConcurrentHashMap#computeIfAbsent [celeborn]
via GitHub
2025/07/28
Re: [PR] [CELEBORN-894][CELEBORN-474][FOLLOWUP] PushState uses JavaUtils#newConcurrentHashMap to speed up ConcurrentHashMap#computeIfAbsent [celeborn]
via GitHub
2025/07/28
[PR] [CELEBORN-894][CELEBORN-474][FOLLOWUP] PushState uses JavaUtils#newConcurrentHashMap to speed up ConcurrentHashMap#computeIfAbsent [celeborn]
via GitHub
2025/07/28
[PR] [CELEBORN-2086] S3FlushTask and OssFlushTask should close ByteArrayInputStream to avoid resource leak [celeborn]
via GitHub
2025/07/28
Re: [PR] [CELEBORN-2053] Refactor remote storage configration usage. [celeborn]
via GitHub
2025/07/28
Re: [PR] [CELEBORN-2053] Refactor remote storage configration usage. [celeborn]
via GitHub
2025/07/28
[PR] [CELEBORN-2085] Use a fixed buffer for flush copying to reduce GC [celeborn]
via GitHub
2025/07/28
Re: [PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/07/28
[PR] [CELEBORN-2084] /api/v1/workers adds tagged workers to list tagged workers information [celeborn]
via GitHub
2025/07/27
Re: [PR] [CELEBORN-2053] Refactor remote storage configration usage. [celeborn]
via GitHub
2025/07/27
Re: [PR] [CELEBORN-2053] Refactor remote storage configration usage. [celeborn]
via GitHub
2025/07/27
Re: [PR] [CELEBORN-2083] For `WorkerStatusTracker`, log error for `recordWorkerFailure` [celeborn]
via GitHub
2025/07/27
Re: [PR] [CELEBORN-2083] For `WorkerStatusTracker`, log error for `recordWorkerFailure` [celeborn]
via GitHub
2025/07/27
[PR] Log error for `recordWorkerFailure` to separate with worker status changed from application heartbeat response [celeborn]
via GitHub
2025/07/27
Re: [PR] [CELEBORN-1984] Merge ResourceRequest to transportMessageProtobuf [celeborn]
via GitHub
2025/07/27
Re: [PR] [CELEBORN-2053] Refactor remote storage configration usage. [celeborn]
via GitHub
2025/07/27
Re: [PR] [CELEBORN-2058] Add retry to avoid commtting failed with HDFS storage [celeborn]
via GitHub
2025/07/26
Re: [PR] [CELEBORN-2058] Add retry to avoid commtting failed with HDFS storage [celeborn]
via GitHub
2025/07/26
Re: [PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/07/26
Re: [PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/07/26
Re: [PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/07/26
Re: [PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/07/26
Re: [PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/07/26
Re: [PR] [CELEBORN-2047] Support MapPartitionData on DFS [celeborn]
via GitHub
2025/07/26
Re: [PR] [CELEBORN-1984] Merge ResourceRequest to transportMessageProtobuf [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-2047] Support MapPartitionData on DFS [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-2064] Fix the issue where reading replica partition that returns zero chunk causes tasks to hang [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-1984] Merge ResourceRequest to transportMessageProtobuf [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-1787] Fix netty memory metrics was not registered when enable memory allocator share [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-1787] Fix netty memory metrics was not registered when enable memory allocator share [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-1787] Fix netty memory metrics was not registered when enable memory allocator share [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-2082] Add the log of excluded workers with high workloads [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-2082] Add the log of excluded workers with high workloads [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-2081] PushDataHandler onFailure log shuffle key [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-2081] PushDataHandler onFailure log shuffle key [celeborn]
via GitHub
2025/07/25
[PR] [CELEBORN-2082] Add the log of excluded workers with high workloads [celeborn]
via GitHub
2025/07/25
[PR] [CELEBORN-2081] PushDataHandler onFailure log shuffle key [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-1793] Add netty pinned memory metrics [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-1793] Add netty pinned memory metrics [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-1793] Add netty pinned memory metrics [celeborn]
via GitHub
2025/07/25
Re: [PR] check unit [celeborn]
via GitHub
2025/07/25
[PR] check unit [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-1787] Fix netty memory metrics was not registered when enable memory allocator share [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-1787] Fix netty memory metrics was not registered when enable memory allocator share [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-1787] Fix netty memory metrics was not registered when enable memory allocator share [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-1787] Fix netty memory metrics was not registered when enable memory allocator share [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-1787] Fix netty memory metrics was not registered when enable memory allocator share [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-1787] Fix netty memory metrics was not registered when enable memory allocator share [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-1787] Fix netty memory metrics was not registered when enable memory allocator share [celeborn]
via GitHub
2025/07/25
Re: [PR] [CELEBORN-1787] Fix netty memory metrics was not registered when enable memory allocator share [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-2079] Fix netty grafana dashboard [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-2079] Fix netty grafana dashboard [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/07/24
[PR] [CELEBORN-1787] Fix netty memory metrics was not registered when enable memory allocator share [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-2079] Fix netty grafana dashboard [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-2056] Make the wait time for the client to read non shuffle partitions configurable [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-2056] Make the wait time for the client to read non shuffle partitions configurable [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-2058] Add retry to avoid commtting failed with HDFS storage [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-1917][FOLLOWUP] Do not wait if total inflight or inflight to a specific worker is lower than threshold [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-1917][FOLLOWUP] Do not wait if total inflight or inflight to a specific worker is lower than threshold [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-1917][FOLLOWUP] Do not wait if total inflight or inflight to a specific worker is lower than threshold [celeborn]
via GitHub
2025/07/24
[PR] [CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-2070][CIP-14] Support MapperEnd/Response in CppClient [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-2056] Make the wait time for the client to read non shuffle partitions configurable [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-2053] Refactor remote storage configration usage. [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-2053] Refactor remote storage configration usage. [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-2056] Make the wait time for the client to read non shuffle partitions configurable [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-1917][FOLLOWUP] Do not wait if total inflight or inflight to a specific worker is lower than threshold [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-2053] Refactor remote storage configration usage. [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-2071] Fix the issue where some gauge metrics were not registered to the metricRegistry [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-2071] Fix the issue where some gauge metrics were not registered to the metricRegistry [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-1776] Add UT when replica enable and workers randomly shutdown [celeborn]
via GitHub
2025/07/24
[PR] [CELEBORN-1776] Add UT when replica enable and workers randomly shutdown [celeborn]
via GitHub
2025/07/24
Re: [PR] [CELEBORN-2079] Fix netty grafana dashboard [celeborn]
via GitHub
2025/07/24
[PR] [CELEBORN-1793] Add netty pinned memory metrics [celeborn]
via GitHub
2025/07/23
Re: [I] Opening an issue in Jira [celeborn]
via GitHub
2025/07/23
Re: [I] Opening an issue in Jira [celeborn]
via GitHub
2025/07/23
Re: [PR] [CELEBORN-2080] Bump Flink from 1.19.2, 1.20.1 to 1.19.3, 1.20.2 [celeborn]
via GitHub
2025/07/23
Re: [PR] [CELEBORN-2080] Bump Flink from 1.19.2, 1.20.1 to 1.19.3, 1.20.2 [celeborn]
via GitHub
2025/07/23
Re: [PR] [CELEBORN-1917][FOLLOWUP] Do not wait if total inflight or inflight to a specific worker is lower than threshold [celeborn]
via GitHub
2025/07/23
[PR] Followup comments [celeborn]
via GitHub
2025/07/23
Re: [PR] [CELEBORN-1917] Support celeborn.client.push.maxBytesSizeInFlight [celeborn]
via GitHub
2025/07/23
[PR] [CELEBORN-2080] Bump Flink from 1.19.2, 1.20.1 to 1.19.3, 1.20.2 [celeborn]
via GitHub
2025/07/23
Re: [I] Opening an issue in Jira [celeborn]
via GitHub
2025/07/23
Re: [PR] [CELEBORN-1841][FOLLOWUP] Support custom implementation of EventExecutorChooser to avoid deadlock when calling await in EventLoop thread for EpollEventLoopGroup [celeborn]
via GitHub
2025/07/23
Re: [PR] [CELEBORN-2070][CIP-14] Support RegisterShuffle, MapperEnd/Response in CppClient [celeborn]
via GitHub
Earlier messages
Later messages