Skip to content

Commit 475abba

Browse files
committed
Trivial fix
1 parent eb1a802 commit 475abba

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/FileIndexSuite.scala

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -425,16 +425,13 @@ class FileIndexSuite extends SharedSparkSession {
425425
stringToFile(file, "text")
426426
}
427427
val path = new Path(dir.getCanonicalPath)
428-
428+
val fileIndex = new InMemoryFileIndex(spark, Seq(path), Map.empty, None)
429429
withSQLConf(SQLConf.IGNORE_DATA_LOCALITY.key -> "false",
430430
"fs.file.impl" -> classOf[SpecialBlockLocationFileSystem].getName) {
431-
val fileIndex = new InMemoryFileIndex(spark, Seq(path), Map.empty, None)
432431
val withBlockLocations = fileIndex.
433432
listLeafFiles(Seq(new Path(partitionDirectory.getPath)))
434433

435-
withSQLConf(SQLConf.IGNORE_DATA_LOCALITY.key -> "true",
436-
"fs.file.impl" -> classOf[SpecialBlockLocationFileSystem].getName) {
437-
val fileIndex = new InMemoryFileIndex(spark, Seq(path), Map.empty, None)
434+
withSQLConf(SQLConf.IGNORE_DATA_LOCALITY.key -> "true") {
438435
val withoutBlockLocations = fileIndex.
439436
listLeafFiles(Seq(new Path(partitionDirectory.getPath)))
440437

0 commit comments

Comments
 (0)