From 21cc1b712ebe553ffc76b2d289ec9a6fac5c49ad Mon Sep 17 00:00:00 2001
From: Xianming Lei <31424839+leixm@users.noreply.github.com>
Date: Wed, 4 Dec 2024 14:35:44 +0800
Subject: [PATCH] fix

---
 .../service/deploy/master/quota/QuotaManager.scala   | 12 +++++++-----
 1 file changed, 7 insertions(+), 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
index 136da4bc805..2011975539f 100644
--- 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,