Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/21594#discussion_r197591943
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/internal/CatalogImpl.scala ---
@@ -438,7 +440,9 @@ class CatalogImpl(sparkSession: SparkSession) extends
Catalog {
* @since 2.0.0
*/
override def uncacheTable(tableName: String): Unit = {
-
sparkSession.sharedState.cacheManager.uncacheQuery(sparkSession.table(tableName))
+ val tableIdent =
sparkSession.sessionState.sqlParser.parseTableIdentifier(tableName)
+ sparkSession.sharedState.cacheManager.uncacheQuery(
+ sparkSession.table(tableName),
!sessionCatalog.isTemporaryTable(tableIdent))
--- End diff --
val cascade = !sessionCatalog.isTemporaryTable(tableIdent)
...
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
