celeborn/client-spark
zky.zhoukeyong cae4de1cc1 [CELEBORN-1301] Catch and throw FetchFailedException in CelebornInputStream#fillBuffer
### What changes were proposed in this pull request?
Catch and throw FetchFailedException in CelebornInputStream#fillBuffer to enable spark's stage rerun
when fillBuffer encounters fetch chunk exception

### Why are the changes needed?
ditto

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

### How was this patch tested?
GA

Closes #2349 from waitinfuture/1301.

Lead-authored-by: zky.zhoukeyong <zky.zhoukeyong@alibaba-inc.com>
Co-authored-by: Keyong Zhou <waitinfuture@gmail.com>
Signed-off-by: zky.zhoukeyong <zky.zhoukeyong@alibaba-inc.com>
2024-03-03 13:32:40 +08:00
..
common [CELEBORN-1242] Unify celeborn thread name format 2024-01-23 16:56:40 +08:00
spark-2 [CELEBORN-1298] Support Spark2.4 with Scala2.12 2024-02-29 17:58:54 +08:00
spark-2-shaded [CELEBORN-1250][FOLLOWUP] Fix license issues 2024-01-30 16:45:21 +08:00
spark-3 [CELEBORN-1301] Catch and throw FetchFailedException in CelebornInputStream#fillBuffer 2024-03-03 13:32:40 +08:00
spark-3-columnar-shuffle [CELEBORN-1150] Revert "[] support io encryption for spark" 2024-01-04 13:00:58 +08:00
spark-3-shaded [CELEBORN-1250][FOLLOWUP] Fix license issues 2024-01-30 16:45:21 +08:00