Skip to content

Commit 083fe21

Browse files
author
brandonlin
committed
check both configs to align the behavior in hive
1 parent 8461e42 commit 083fe21

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveMetastoreCatalog.scala

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -281,9 +281,11 @@ private[hive] class HiveMetastoreCatalog(sparkSession: SparkSession) extends Log
281281
private def getDirectoryPathSeq(rootPath: Path): Seq[String] = {
282282
val enableSupportSubDirectories =
283283
sparkSession.sparkContext.
284-
hadoopConfiguration.get("hive.mapred.supports.subdirectories", "false")
284+
hadoopConfiguration.getBoolean("hive.mapred.supports.subdirectories", false) &&
285+
sparkSession.sparkContext.
286+
hadoopConfiguration.getBoolean("mapred.input.dir.recursive", false)
285287

286-
if (enableSupportSubDirectories.toBoolean) {
288+
if (enableSupportSubDirectories) {
287289
val fs = rootPath.getFileSystem(sparkSession.sessionState.newHadoopConf())
288290
SparkHadoopUtil.get.listLeafDirStatuses(fs, rootPath).map(_.getPath.toString)
289291
} else {

sql/hive/src/test/scala/org/apache/spark/sql/hive/HiveMetastoreCatalogSuite.scala

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -372,6 +372,9 @@ class DataSourceWithHiveMetastoreCatalogSuite
372372
spark.sparkContext
373373
.hadoopConfiguration.set("hive.mapred.supports.subdirectories", "true")
374374

375+
spark.sparkContext
376+
.hadoopConfiguration.set("mapred.input.dir.recursive", "true")
377+
375378
val dataFrame = spark.sqlContext
376379
.createDataFrame(testData, StructType(Seq(StructField("val", IntegerType))))
377380

0 commit comments

Comments
 (0)