aboutsummaryrefslogtreecommitdiff
path: root/sql/core/src/test/scala
diff options
context:
space:
mode:
Diffstat (limited to 'sql/core/src/test/scala')
-rw-r--r--sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/FileCatalogSuite.scala11
1 files changed, 11 insertions, 0 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/FileCatalogSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/FileCatalogSuite.scala
index 0d9ea51272..5c8d3226e9 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/FileCatalogSuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/FileCatalogSuite.scala
@@ -67,4 +67,15 @@ class FileCatalogSuite extends SharedSQLContext {
}
}
+
+ test("ListingFileCatalog: folders that don't exist don't throw exceptions") {
+ withTempDir { dir =>
+ val deletedFolder = new File(dir, "deleted")
+ assert(!deletedFolder.exists())
+ val catalog1 = new ListingFileCatalog(
+ spark, Seq(new Path(deletedFolder.getCanonicalPath)), Map.empty, None)
+ // doesn't throw an exception
+ assert(catalog1.listLeafFiles(catalog1.paths).isEmpty)
+ }
+ }
}