Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21408#discussion_r190199737
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/InMemoryFileIndex.scala
---
@@ -311,14 +314,27 @@ object InMemoryFileIndex extends Logging {
// The other constructor of LocatedFileStatus will call
FileStatus.getPermission(),
// which is very slow on some file system (RawLocalFileSystem,
which is launch a
// subprocess and parse the stdout).
- val locations = fs.getFileBlockLocations(f, 0, f.getLen)
- val lfs = new LocatedFileStatus(f.getLen, f.isDirectory,
f.getReplication, f.getBlockSize,
- f.getModificationTime, 0, null, null, null, null, f.getPath,
locations)
- if (f.isSymlink) {
- lfs.setSymlink(f.getSymlink)
+ try {
--- End diff --
only diff here is try and catch
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
