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 27a76c1 commit ca6d3cdCopy full SHA for ca6d3cd
sql/core/src/main/scala/org/apache/spark/sql/execution/command/ddl.scala
@@ -587,7 +587,7 @@ case class AlterTableRecoverPartitionsCommand(
587
val threshold = spark.conf.get("spark.rdd.parallelListingThreshold", "10").toInt
588
val hadoopConf = spark.sparkContext.hadoopConfiguration
589
val pathFilter = getPathFilter(hadoopConf)
590
-
+
591
val evalPool = ThreadUtils.newForkJoinPool("AlterTableRecoverPartitionsCommand", 8)
592
val partitionSpecsAndLocs: Seq[(TablePartitionSpec, Path)] =
593
try {
0 commit comments