Skip to content

Commit 7f7ffac

Browse files
committed
Enhance logs
1 parent 38803c2 commit 7f7ffac

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1146,6 +1146,9 @@ final private[worker] class StorageManager(conf: CelebornConf, workerSource: Abs
11461146
} else {
11471147
if (suggestedMountPoint.isEmpty) {
11481148
logDebug(s"Location suggestedMountPoint is not set, return all healthy working dirs.")
1149+
} else if (diskInfo == null) {
1150+
logInfo(s"Disk info not found for suggestedMountPoint $suggestedMountPoint, return all healthy " +
1151+
s"working dirs.")
11491152
} else {
11501153
logInfo(s"Disk(${diskInfo.mountPoint}) unavailable for $suggestedMountPoint, return all healthy" +
11511154
s" working dirs.")

0 commit comments

Comments
 (0)