We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6d6ae34 commit 849603bCopy full SHA for 849603b
sql/core/src/main/scala/org/apache/spark/sql/parquet/newParquet.scala
@@ -269,7 +269,7 @@ private[sql] case class ParquetRelation2(
269
val baseStatuses = paths.distinct.map { p =>
270
val fs = FileSystem.get(URI.create(p), sparkContext.hadoopConfiguration)
271
val path = new Path(p)
272
- val qualified = path.makeQualified(fs)
+ val qualified = path.makeQualified(fs.getUri, fs.getWorkingDirectory)
273
274
if (!fs.exists(qualified) && maybeSchema.isDefined) {
275
fs.mkdirs(qualified)
0 commit comments