diff --git a/sql/core/src/main/scala/org/apache/spark/sql/sources/interfaces.scala b/sql/core/src/main/scala/org/apache/spark/sql/sources/interfaces.scala index b66fa3a43ade2..da9fc8bca77a5 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/sources/interfaces.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/sources/interfaces.scala @@ -372,7 +372,7 @@ abstract class HadoopFsRelation private[sql](maybePartitionSpec: Option[Partitio var leafDirs = mutable.Map.empty[Path, FileStatus] - def refresh() = { + def refresh(): Unit = { def listLeafFilesAndDirs(fs: FileSystem, status: FileStatus): Set[FileStatus] = { val (dirs, files) = fs.listStatus(status.getPath).partition(_.isDir) val leafDirs = if (dirs.isEmpty) Set(status) else Set.empty[FileStatus]