Github user kiszk commented on a diff in the pull request:
https://github.com/apache/spark/pull/19133#discussion_r137857334
--- Diff:
core/src/main/scala/org/apache/spark/storage/DiskBlockManager.scala ---
@@ -53,7 +53,7 @@ private[spark] class DiskBlockManager(conf: SparkConf,
deleteFilesOnStop: Boolea
/** Looks up a file by hashing it into one of our local subdirectories.
*/
// This method should be kept in sync with
//
org.apache.spark.network.shuffle.ExternalShuffleBlockResolver#getFile().
- def getFile(filename: String): File = {
+ private def getFileInternal(filename: String): File = {
--- End diff --
Why do we need this rename?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
