From 9e47b1a7e47fde1d4d47029db40018d965b0df7c Mon Sep 17 00:00:00 2001 From: Cheng Pan Date: Wed, 5 Jul 2023 19:50:56 +0800 Subject: [PATCH] Update master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala --- .../org/apache/celeborn/service/deploy/master/Master.scala | 4 ++-- 1 file changed, 2 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 30fa65de49f..4e21d6d3ce1 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 @@ -702,8 +702,8 @@ private[celeborn] class Master( val fileStatus = iter.next() if (!statusSystem.appHeartbeatTime.containsKey(fileStatus.getPath.getName)) { logInfo( - s"Clean HDFS dir ${fileStatus.getPath.toString} using ${Utils.msDurationToString( - System.currentTimeMillis() - startTime)}") + s"Clean HDFS dir ${fileStatus.getPath.toString} costs + ${Utils.msDurationToString(System.currentTimeMillis() - startTime)}") hadoopFs.delete(fileStatus.getPath, true) } }