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,