Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/19444#discussion_r143235124
--- Diff:
sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala
---
@@ -638,12 +638,14 @@ private[hive] class HiveClientImpl(
table: CatalogTable,
spec: Option[TablePartitionSpec]): Seq[CatalogTablePartition] =
withHiveState {
val hiveTable = toHiveTable(table, Some(userName))
- val parts = spec match {
- case None => shim.getAllPartitions(client,
hiveTable).map(fromHivePartition)
+ val partialPartSpec = spec match {
--- End diff --
-> `partSpec`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
