File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions
core/src/main/scala/org/apache/spark/sql/parquet Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -193,6 +193,8 @@ class SpecificMutableRow(val values: Array[MutableValue]) extends MutableRow {
193193 case ByteType => new MutableByte
194194 case FloatType => new MutableFloat
195195 case ShortType => new MutableShort
196+ case DoubleType => new MutableDouble
197+ case BooleanType => new MutableBoolean
196198 case LongType => new MutableLong
197199 case _ => new MutableAny
198200 }.toArray)
Original file line number Diff line number Diff line change @@ -376,8 +376,6 @@ private[parquet] object ParquetTypesConverter extends Logging {
376376 }
377377 ParquetRelation .enableLogForwarding()
378378
379- println(fs.listStatus(path).toSeq)
380-
381379 val children = fs.listStatus(path).filterNot { status =>
382380 val name = status.getPath.getName
383381 name(0 ) == '.' || name == FileOutputCommitter .SUCCEEDED_FILE_NAME
@@ -395,7 +393,7 @@ private[parquet] object ParquetTypesConverter extends Logging {
395393 .orElse(children.find(_.getPath.getName == ParquetFileWriter .PARQUET_METADATA_FILE ))
396394 .map(ParquetFileReader .readFooter(conf, _))
397395 .getOrElse(
398- throw new IllegalArgumentException (s " Could not find Parquet metadata at path $path in ${children.map(_.getPath.getName).toSeq} " ))
396+ throw new IllegalArgumentException (s " Could not find Parquet metadata at path $path" ))
399397 }
400398
401399 /**
You can’t perform that action at this time.
0 commit comments