celeborn/client-flink
mingji 3ec218878a
[CELEBORN-876] Enhance log to find out failed workers if data lost
### What changes were proposed in this pull request?
1. Log offer slots results from LifecycleManager.
2. Log change partition results from LifecycleManager.
3. Log reserve slots results.
4. Log fetch file group failure instead of data lost.

### Why are the changes needed?
If data lost happened, we need to find out what worker cause this failure. So we need to check reserve slots result from LifecycleManager.

### Does this PR introduce _any_ user-facing change?
NO.

### How was this patch tested?
GA.

Closes #1798 from FMX/CELEBORN-876.

Authored-by: mingji <fengmingxiao.fmx@alibaba-inc.com>
Signed-off-by: mingji <fengmingxiao.fmx@alibaba-inc.com>
2023-08-08 18:20:41 +08:00
..
common [CELEBORN-876] Enhance log to find out failed workers if data lost 2023-08-08 18:20:41 +08:00
flink-1.14 [CELEBORN-717][FLINK][FOLLOWUP] Fix ResultPartition lost numBytesOut/numBuffersOut metrics 2023-06-27 21:47:41 +08:00
flink-1.14-shaded [CELEBORN-716][BUILD] Correct the to name when renaming the Netty native library 2023-06-26 21:57:06 +08:00
flink-1.15 [CELEBORN-717][FLINK][FOLLOWUP] Fix ResultPartition lost numBytesOut/numBuffersOut metrics 2023-06-27 21:47:41 +08:00
flink-1.15-shaded [CELEBORN-716][BUILD] Correct the to name when renaming the Netty native library 2023-06-26 21:57:06 +08:00
flink-1.17 [CELEBORN-717][FLINK][FOLLOWUP] Fix ResultPartition lost numBytesOut/numBuffersOut metrics 2023-06-27 21:47:41 +08:00
flink-1.17-shaded [CELEBORN-716][BUILD] Correct the to name when renaming the Netty native library 2023-06-26 21:57:06 +08:00