Change the variable name so that the passed parameters are correct (#12)

* Create BlockManager.scala * Update BlockManager.scala * Update BlockManager.scala
oap-project · Feb 5, 2021 · 0d1e009 · 0d1e009
1 parent 032cbae
commit 0d1e009
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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) {