Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/21001#discussion_r180397137
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/InMemoryCatalog.scala
---
@@ -187,38 +187,32 @@ class InMemoryCatalog(
val db = tableDefinition.identifier.database.get
requireDbExists(db)
val table = tableDefinition.identifier.table
- if (tableExists(db, table)) {
- if (!ignoreIfExists) {
- throw new TableAlreadyExistsException(db = db, table = table)
--- End diff --
We should not remove this logic here, even it's also done in
`SessionCatalog`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
