Github user viirya commented on a diff in the pull request: https://github.com/apache/spark/pull/19405#discussion_r142059110 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/internal/CatalogImpl.scala --- @@ -474,13 +474,20 @@ class CatalogImpl(sparkSession: SparkSession) extends Catalog { */ override def refreshTable(tableName: String): Unit = { val tableIdent = sparkSession.sessionState.sqlParser.parseTableIdentifier(tableName) - // Temp tables: refresh (or invalidate) any metadata/data cached in the plan recursively. - // Non-temp tables: refresh the metadata cache. - sessionCatalog.refreshTable(tableIdent) - + val tableMetadata = sessionCatalog.getTempViewOrPermanentTableMetadata(tableIdent) // If this table is cached as an InMemoryRelation, drop the original --- End diff -- This comment should be moved to line 491.
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org