You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by we...@apache.org on 2017/03/16 00:45:07 UTC
spark git commit: [SPARK-19961][SQL][MINOR] unify a erro msg when
drop databse for HiveExternalCatalog and InMemoryCatalog
Repository: spark
Updated Branches:
refs/heads/master 339b237dc -> fc9314671
[SPARK-19961][SQL][MINOR] unify a erro msg when drop databse for HiveExternalCatalog and InMemoryCatalog
## What changes were proposed in this pull request?
unify a exception erro msg for dropdatabase when the database still have some tables for HiveExternalCatalog and InMemoryCatalog
## How was this patch tested?
N/A
Author: windpiger <so...@outlook.com>
Closes #17305 from windpiger/unifyErromsg.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/fc931467
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/fc931467
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/fc931467
Branch: refs/heads/master
Commit: fc9314671c8a082ae339fd6df177a2b684c65d40
Parents: 339b237
Author: windpiger <so...@outlook.com>
Authored: Thu Mar 16 08:44:57 2017 +0800
Committer: Wenchen Fan <we...@databricks.com>
Committed: Thu Mar 16 08:44:57 2017 +0800
----------------------------------------------------------------------
.../apache/spark/sql/catalyst/catalog/InMemoryCatalog.scala | 2 +-
.../org/apache/spark/sql/execution/command/DDLSuite.scala | 8 ++------
2 files changed, 3 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/fc931467/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/InMemoryCatalog.scala
----------------------------------------------------------------------
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/InMemoryCatalog.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/InMemoryCatalog.scala
index 5cc6b0a..cdf618a 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/InMemoryCatalog.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/InMemoryCatalog.scala
@@ -127,7 +127,7 @@ class InMemoryCatalog(
if (!cascade) {
// If cascade is false, make sure the database is empty.
if (catalog(db).tables.nonEmpty) {
- throw new AnalysisException(s"Database '$db' is not empty. One or more tables exist.")
+ throw new AnalysisException(s"Database $db is not empty. One or more tables exist.")
}
if (catalog(db).functions.nonEmpty) {
throw new AnalysisException(s"Database '$db' is not empty. One or more functions exist.")
http://git-wip-us.apache.org/repos/asf/spark/blob/fc931467/sql/core/src/test/scala/org/apache/spark/sql/execution/command/DDLSuite.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/command/DDLSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/command/DDLSuite.scala
index 6eed10e..dd76fdd 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/execution/command/DDLSuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/command/DDLSuite.scala
@@ -617,12 +617,8 @@ abstract class DDLSuite extends QueryTest with SQLTestUtils {
val message = intercept[AnalysisException] {
sql(s"DROP DATABASE $dbName RESTRICT")
}.getMessage
- // TODO: Unify the exception.
- if (isUsingHiveMetastore) {
- assert(message.contains(s"Database $dbName is not empty. One or more tables exist"))
- } else {
- assert(message.contains(s"Database '$dbName' is not empty. One or more tables exist"))
- }
+ assert(message.contains(s"Database $dbName is not empty. One or more tables exist"))
+
catalog.dropTable(tableIdent1, ignoreIfNotExists = false, purge = false)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org