Fixed DiskBlockManagerSuite

Sergei Lebedev · Sergei Lebedev · commit 2b6134708e17 · 2017-10-25T14:15:11.000+02:00
diff --git a/core/src/test/scala/org/apache/spark/storage/DiskBlockManagerSuite.scala b/core/src/test/scala/org/apache/spark/storage/DiskBlockManagerSuite.scala
@@ -81,8 +81,7 @@ class DiskBlockManagerSuite extends SparkFunSuite with BeforeAndAfterEach with B
   }
 
   test("SPARK-22227: non-block files are skipped") {
-    val blockId = TempShuffleBlockId(UUID.randomUUID())
-    val file = diskBlockManager.getFile(blockId)
+    val file = diskBlockManager.getFile("unmanaged_file")
     writeToFile(file, 10)
     assert(diskBlockManager.getAllBlocks().isEmpty)
   }

Original file line number	Diff line number	Diff line change
`@@ -81,8 +81,7 @@ class DiskBlockManagerSuite extends SparkFunSuite with BeforeAndAfterEach with B`
`81`	`81`	`}`
`82`	`82`
`83`	`83`	`test("SPARK-22227: non-block files are skipped") {`
`84`		`- val blockId = TempShuffleBlockId(UUID.randomUUID())`
`85`		`- val file = diskBlockManager.getFile(blockId)`
	`84`	`+ val file = diskBlockManager.getFile("unmanaged_file")`
`86`	`85`	`writeToFile(file, 10)`
`87`	`86`	`assert(diskBlockManager.getAllBlocks().isEmpty)`
`88`	`87`	`}`