This is an automated email from the ASF dual-hosted git repository.
zhouky pushed a commit to branch branch-0.3
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git
The following commit(s) were added to refs/heads/branch-0.3 by this push:
new a68e58ee6 [MINOR] Update log level of CommitFiles success for
`CommitHandler` from error to info
a68e58ee6 is described below
commit a68e58ee698d2557fdf62a92c2a6cfe882876eab
Author: SteNicholas <[email protected]>
AuthorDate: Wed Dec 20 15:13:38 2023 +0800
[MINOR] Update log level of CommitFiles success for `CommitHandler` from
error to info
### What changes were proposed in this pull request?
Update log level of CommitFiles success for `CommitHandler` from error to
info.
### Why are the changes needed?
The log level of sending CommitFiles success for `CommitHandler` should not
be error.
### Does this PR introduce _any_ user-facing change?
No.
### How was this patch tested?
No.
Closes #2174 from SteNicholas/commit-files-log.
Authored-by: SteNicholas <[email protected]>
Signed-off-by: zky.zhoukeyong <[email protected]>
---
.../main/scala/org/apache/celeborn/client/commit/CommitHandler.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala
b/client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala
index 28d64fbe7..632d407da 100644
---
a/client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala
+++
b/client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala
@@ -305,7 +305,7 @@ abstract class CommitHandler(
case scala.util.Success(res) =>
res.status match {
case StatusCode.SUCCESS | StatusCode.PARTIAL_SUCCESS |
StatusCode.SHUFFLE_NOT_REGISTERED | StatusCode.REQUEST_FAILED |
StatusCode.WORKER_EXCLUDED =>
- logError(s"Request commitFiles return ${res.status} for " +
+ logInfo(s"Request commitFiles return ${res.status} for " +
s"${Utils.makeShuffleKey(appUniqueId, shuffleId)}")
if (res.status != StatusCode.SUCCESS && res.status !=
StatusCode.WORKER_EXCLUDED) {
commitFilesFailedWorkers.put(worker, (res.status,
System.currentTimeMillis()))
