diff --git a/sql/core/src/main/scala/org/apache/spark/sql/parquet/ParquetTypes.scala b/sql/core/src/main/scala/org/apache/spark/sql/parquet/ParquetTypes.scala index c79a9ac2dad81..27d18f245b125 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/parquet/ParquetTypes.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/parquet/ParquetTypes.scala @@ -376,6 +376,8 @@ private[parquet] object ParquetTypesConverter extends Logging { } ParquetRelation.enableLogForwarding() + println(fs.listStatus(path).toSeq) + val children = fs.listStatus(path).filterNot { status => val name = status.getPath.getName name(0) == '.' || name == FileOutputCommitter.SUCCEEDED_FILE_NAME @@ -393,7 +395,7 @@ private[parquet] object ParquetTypesConverter extends Logging { .orElse(children.find(_.getPath.getName == ParquetFileWriter.PARQUET_METADATA_FILE)) .map(ParquetFileReader.readFooter(conf, _)) .getOrElse( - throw new IllegalArgumentException(s"Could not find Parquet metadata at path $path")) + throw new IllegalArgumentException(s"Could not find Parquet metadata at path $path in ${children.map(_.getPath.getName).toSeq}")) } /**