Skip to content

Commit

Permalink
include the syncup response error messages as a string to help debug
Browse files Browse the repository at this point in the history
Signed-off-by: Xun Zhang <[email protected]>
  • Loading branch information
Zhangxunmt committed May 4, 2024
1 parent 6294a96 commit 7ae48a4
Showing 1 changed file with 6 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -100,7 +100,12 @@ public void run() {
client.execute(MLSyncUpAction.INSTANCE, gatherInfoRequest, ActionListener.wrap(r -> {
List<MLSyncUpNodeResponse> responses = r.getNodes();
if (r.failures() != null && r.failures().size() != 0) {
log.error("Received {} failures in the sync up response on nodes", r.failures().size());
log
.debug(
"Received {} failures in the sync up response on nodes. Error messages are {}",
r.failures().size(),
r.failures().stream().map(Exception::getMessage).collect(Collectors.joining(", "))
);
}
// key is model id, value is set of worker node ids
Map<String, Set<String>> modelWorkerNodes = new HashMap<>();
Expand Down

0 comments on commit 7ae48a4

Please sign in to comment.