fix

apache · Dec 4, 2024 · 21cc1b7 · 21cc1b7
1 parent 29e27cd
commit 21cc1b7
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/master/src/main/scala/org/apache/celeborn/service/deploy/master/quota/QuotaManager.scala b/master/src/main/scala/org/apache/celeborn/service/deploy/master/quota/QuotaManager.scala
@@ -49,11 +49,13 @@ class QuotaManager(
   private val quotaChecker =
     ThreadUtils.newDaemonSingleThreadScheduledExecutor("master-quota-checker")
   quotaChecker.scheduleWithFixedDelay(
-    () => {
-      try {
-        updateResourceConsumption()
-      } catch {
-        case t: Throwable => logError("Update user resource consumption failed.", t)
+    new Runnable {
+      override def run(): Unit = {
+        try {
+          updateResourceConsumption()
+        } catch {
+          case t: Throwable => logError("Update user resource consumption failed.", t)
+        }
       }
     },
     0L,