[incubator-celeborn] branch main updated: [CELEBORN-109][FEATURE] Add new DiskStatus to represent critical error (#1054)

[zhouky]

This is an automated email from the ASF dual-hosted git repository.

zhouky 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 426918c1 [CELEBORN-109][FEATURE] Add new DiskStatus to represent 
critical error (#1054)
426918c1 is described below

commit 426918c1cd9c25be7b8452491a16c83cbaf3c531
Author: nafiy <30563796+nafiy...@users.noreply.github.com>
AuthorDate: Thu Dec 8 11:34:58 2022 +0800

    [CELEBORN-109][FEATURE] Add new DiskStatus to represent critical error 
(#1054)
---
 common/src/main/java/org/apache/celeborn/common/meta/DiskStatus.java | 3 ++-
 common/src/main/scala/org/apache/celeborn/common/util/Utils.scala    | 1 +
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/common/src/main/java/org/apache/celeborn/common/meta/DiskStatus.java 
b/common/src/main/java/org/apache/celeborn/common/meta/DiskStatus.java
index 66e61904..c7b6aff9 100644
--- a/common/src/main/java/org/apache/celeborn/common/meta/DiskStatus.java
+++ b/common/src/main/java/org/apache/celeborn/common/meta/DiskStatus.java
@@ -21,7 +21,8 @@ public enum DiskStatus {
   HEALTHY(0),
   READ_OR_WRITE_FAILURE(1),
   IO_HANG(2),
-  HIGH_DISK_USAGE(3);
+  HIGH_DISK_USAGE(3),
+  CRITICAL_ERROR(4);
 
   private final byte value;
 
diff --git a/common/src/main/scala/org/apache/celeborn/common/util/Utils.scala 
b/common/src/main/scala/org/apache/celeborn/common/util/Utils.scala
index 592351c9..b8b6a0a4 100644
--- a/common/src/main/scala/org/apache/celeborn/common/util/Utils.scala
+++ b/common/src/main/scala/org/apache/celeborn/common/util/Utils.scala
@@ -926,6 +926,7 @@ object Utils extends Logging {
       case 1 => DiskStatus.READ_OR_WRITE_FAILURE
       case 2 => DiskStatus.IO_HANG
       case 3 => DiskStatus.HIGH_DISK_USAGE
+      case 4 => DiskStatus.CRITICAL_ERROR
       case _ => null
     }
   }