This is an automated email from the ASF dual-hosted git repository. ethanfeng pushed a commit to branch branch-0.2 in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git
commit 1fd2251475aa76855158505969345d91502c724a Author: Ethan Feng <[email protected]> AuthorDate: Tue Feb 14 15:44:20 2023 +0800 [CELEBORN-300] fix a bug about non-leader master try to update partition size. (#1235) (cherry picked from commit d391e7d91d1b1ed19a5c501632685a1774cde2c5) --- .../scala/org/apache/celeborn/service/deploy/master/Master.scala | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala b/master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala index ba30c934..9952d8b7 100644 --- a/master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala +++ b/master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala @@ -117,8 +117,11 @@ private[celeborn] class Master( partitionSizeUpdateService.scheduleAtFixedRate( new Runnable { override def run(): Unit = { - statusSystem.handleUpdatePartitionSize() - logInfo(s"Cluster estimate partition size ${Utils.bytesToString(statusSystem.estimatedPartitionSize)}") + executeWithLeaderChecker( + null, { + statusSystem.handleUpdatePartitionSize() + logInfo(s"Cluster estimate partition size ${Utils.bytesToString(statusSystem.estimatedPartitionSize)}") + }) } }, estimatedPartitionSizeUpdaterInitialDelay,
