From 2613516110a488c1061772583169512c15c83e5b Mon Sep 17 00:00:00 2001 From: Dongjoon Hyun Date: Fri, 19 Apr 2024 19:59:02 -0700 Subject: [PATCH] [SPARK-47924][CORE] Add a DEBUG log to `DiskStore.moveFileToBlock` ### What changes were proposed in this pull request? This PR aims to add a DEBUG-level log to `DiskStore.moveFileToBlock` for traceability. ### Why are the changes needed? This helps the Spark debugging. ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? Pass the CIs and manual review because this is a LOG. ### Was this patch authored or co-authored using generative AI tooling? No. Closes #46144 from dongjoon-hyun/SPARK-47924. Authored-by: Dongjoon Hyun Signed-off-by: Dongjoon Hyun --- core/src/main/scala/org/apache/spark/storage/DiskStore.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/scala/org/apache/spark/storage/DiskStore.scala b/core/src/main/scala/org/apache/spark/storage/DiskStore.scala index 54c5d0b2dce71..442b74ba9a237 100644 --- a/core/src/main/scala/org/apache/spark/storage/DiskStore.scala +++ b/core/src/main/scala/org/apache/spark/storage/DiskStore.scala @@ -148,6 +148,7 @@ private[spark] class DiskStore( def moveFileToBlock(sourceFile: File, blockSize: Long, targetBlockId: BlockId): Unit = { blockSizes.put(targetBlockId, blockSize) val targetFile = diskManager.getFile(targetBlockId.name) + logDebug(s"${sourceFile.getPath()} -> ${targetFile.getPath()}") FileUtils.moveFile(sourceFile, targetFile) }