You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@celeborn.apache.org by an...@apache.org on 2023/01/03 09:13:35 UTC
[incubator-celeborn] branch main updated: [CELEBORN-191][BUG] ShuffleClient registerShuffle return RESERVE_SLOTS_FAILED should also been print out (#1138)
This is an automated email from the ASF dual-hosted git repository.
angerszhuuuu pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git
The following commit(s) were added to refs/heads/main by this push:
new 2315f2f9 [CELEBORN-191][BUG] ShuffleClient registerShuffle return RESERVE_SLOTS_FAILED should also been print out (#1138)
2315f2f9 is described below
commit 2315f2f9882ad80e9ede6c0cd88180875d47cab0
Author: Angerszhuuuu <an...@gmail.com>
AuthorDate: Tue Jan 3 17:13:31 2023 +0800
[CELEBORN-191][BUG] ShuffleClient registerShuffle return RESERVE_SLOTS_FAILED should also been print out (#1138)
---
.../src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java b/client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java
index 20e5beb2..04c951ff 100644
--- a/client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java
+++ b/client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java
@@ -336,6 +336,11 @@ public class ShuffleClientImpl extends ShuffleClient {
"LifecycleManager request slots return {}, retry again, remain retry times {}",
StatusCode.SLOT_NOT_AVAILABLE,
numRetries - 1);
+ } else if (StatusCode.RESERVE_SLOTS_FAILED.equals(respStatus)) {
+ logger.error(
+ "LifecycleManager request slots return {}, retry again, remain retry times {}",
+ StatusCode.RESERVE_SLOTS_FAILED,
+ numRetries - 1);
} else {
logger.error(
"LifecycleManager request slots return {}, retry again, remain retry times {}",