From 0d1e009dcbda47c778bdcf74a98fcb1e9edcbcff Mon Sep 17 00:00:00 2001 From: Song Qi <37234782+JustDoCoder@users.noreply.github.com> Date: Fri, 5 Feb 2021 09:07:06 +0800 Subject: [PATCH] Change the variable name so that the passed parameters are correct (#12) * Create BlockManager.scala * Update BlockManager.scala * Update BlockManager.scala --- src/main/scala/org/apache/spark/storage/BlockManager.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/scala/org/apache/spark/storage/BlockManager.scala b/src/main/scala/org/apache/spark/storage/BlockManager.scala index 93c0780c..81e7047d 100644 --- a/src/main/scala/org/apache/spark/storage/BlockManager.scala +++ b/src/main/scala/org/apache/spark/storage/BlockManager.scala @@ -210,8 +210,8 @@ private[spark] class BlockManager( } require(file.isDirectory(), "PMem directory is required for initialization") - PersistentMemoryPlatform.initialize(initPath, pmemInitialSize, 0) - logInfo(s"Intel Optane PMem initialized with path: ${initPath}, size: ${pmemInitialSize} ") + PersistentMemoryPlatform.initialize(file.getAbsolutePath, pmemInitialSize, 0) + logInfo(s"Intel Optane PMem initialized with path: ${file.getAbsolutePath}, size: ${pmemInitialSize} ") } } else if (pmemMode.equals("KMemDax")) { if (!isDriver) {