celeborn/worker
lvshuang.xjs 0e3bc383a5
[CELEBORN-1379] Catch Throwable for ReadBufferDispatcher thread
### What changes were proposed in this pull request?
Catch throwable and release unused buffers.

### Why are the changes needed?
When the BufferAllocator tries to allocate a new ByteBuf, it may throw an OutOfDirectMemoryError. We should catch Throwable in ReadBufferDispatcher to avoid the thread from exiting.

### Does this PR introduce _any_ user-facing change?
No

### How was this patch tested?
Pass GA

Closes #2452 from RexXiong/CELEBORN-1379.

Lead-authored-by: lvshuang.xjs <lvshuang.xjs@taobao.com>
Co-authored-by: Shuang <lvshuang.xjs@alibaba-inc.com>
Signed-off-by: mingji <fengmingxiao.fmx@alibaba-inc.com>
2024-04-11 16:07:04 +08:00
..
src [CELEBORN-1379] Catch Throwable for ReadBufferDispatcher thread 2024-04-11 16:07:04 +08:00
pom.xml [CELEBORN-1317] Refine celeborn http server and support swagger ui 2024-03-27 23:18:18 +08:00