File tree Expand file tree Collapse file tree 2 files changed +0
-2
lines changed
main/scala/org/apache/spark/storage
test/scala/org/apache/spark/storage Expand file tree Collapse file tree 2 files changed +0
-2
lines changed Original file line number Diff line number Diff line change @@ -1281,7 +1281,6 @@ private[spark] class BlockManager(
12811281 numPeersToReplicateTo - peersReplicatedTo.size)
12821282 }
12831283 }
1284-
12851284 logDebug(s " Replicating $blockId of ${data.size} bytes to " +
12861285 s " ${peersReplicatedTo.size} peer(s) took ${(System .nanoTime - startTime) / 1e6 } ms " )
12871286 if (peersReplicatedTo.size < numPeersToReplicateTo) {
Original file line number Diff line number Diff line change @@ -39,7 +39,6 @@ import org.apache.spark.shuffle.sort.SortShuffleManager
3939import org .apache .spark .storage .StorageLevel ._
4040import org .apache .spark .util .Utils
4141
42-
4342trait BlockManagerReplicationBehavior extends SparkFunSuite
4443 with Matchers
4544 with BeforeAndAfter
You can’t perform that action at this time.
0 commit comments