Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 14 additions & 1 deletion core/src/main/scala/org/apache/spark/util/FileLogger.scala
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,20 @@ private[spark] class FileLogger(
override def initialValue(): SimpleDateFormat = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss")
}

private val fileSystem = Utils.getHadoopFileSystem(logDir)
/**
* To avoid effects of FileSystem#close or FileSystem.closeAll called from other modules,
* create unique FileSystem instance only for FileLogger
*/
private val fileSystem = {
val conf = SparkHadoopUtil.get.newConfiguration()
val logUri = new URI(logDir)
val scheme = logUri.getScheme
if (scheme == "hdfs") {
conf.setBoolean("fs.hdfs.impl.disable.cache", true)
}
FileSystem.get(logUri, conf)
}

var fileIndex = 0

// Only used if compression is enabled
Expand Down