This is an automated email from the ASF dual-hosted git repository.
rexxiong pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/celeborn.git
from 298eadb8f [CELEBORN-1645] Introduce ShuffleFallbackPolicy to support
custom implementation of shuffle fallback policy for
CelebornShuffleFallbackPolicyRunner
add af930e7f6 [CELEBORN-1652] Throw TransportableError for failure of
sending PbReadAddCredit to avoid flink task get stuck
No new revisions were added by this update.
Summary of changes:
.../celeborn/plugin/flink/readclient/CelebornBufferStream.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)