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.
Partition.getPartitionPath()
1 parent 9d75854 commit 5a5ff74Copy full SHA for 5a5ff74
sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala
@@ -658,7 +658,7 @@ private[hive] class HiveClientImpl(
658
// Check whether the partition we are going to drop is empty.
659
// We make a dummy one for the empty partition. See [SPARK-29786] for more details.
660
parts.foreach { partition =>
661
- val partPath = partition.getPartitionPath
+ val partPath = partition.getPath.head
662
if (isEmptyPath(partPath)) {
663
val fs = partPath.getFileSystem(conf)
664
fs.mkdirs(partPath)
0 commit comments