Skip to content

Commit 2467732

Browse files
committed
Now that we delegate this to the existing blockmanager logic we don't need an explicit test for it here and the block manager is stubbed out in IndexShuffleBlockResolverSuite
1 parent 9d210f5 commit 2467732

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

core/src/test/scala/org/apache/spark/shuffle/sort/IndexShuffleBlockResolverSuite.scala

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,6 @@ class IndexShuffleBlockResolverSuite extends SparkFunSuite with BeforeAndAfterEa
7474
}
7575
resolver.writeIndexFileAndCommit(shuffleId, mapId, lengths, dataTmp)
7676

77-
val storedShuffles = resolver.getStoredShuffles()
7877
val indexFile = new File(tempDir.getAbsolutePath, idxName)
7978
val dataFile = resolver.getDataFile(shuffleId, mapId)
8079

@@ -83,7 +82,6 @@ class IndexShuffleBlockResolverSuite extends SparkFunSuite with BeforeAndAfterEa
8382
assert(dataFile.exists())
8483
assert(dataFile.length() === 30)
8584
assert(!dataTmp.exists())
86-
assert(storedShuffles === Set(ShuffleBlockInfo(1, 2)))
8785

8886
val lengths2 = new Array[Long](3)
8987
val dataTmp2 = File.createTempFile("shuffle", null, tempDir)

0 commit comments

Comments
 (0)