diff options
Diffstat (limited to 'sql/hive/src/test')
-rw-r--r-- | sql/hive/src/test/scala/org/apache/spark/sql/hive/MultiDatabaseSuite.scala | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/MultiDatabaseSuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/MultiDatabaseSuite.scala index 9f4401ae22..7322465109 100644 --- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/MultiDatabaseSuite.scala +++ b/sql/hive/src/test/scala/org/apache/spark/sql/hive/MultiDatabaseSuite.scala @@ -269,17 +269,17 @@ class MultiDatabaseSuite extends QueryTest with SQLTestUtils with TestHiveSingle val message = intercept[AnalysisException] { df.write.format("parquet").saveAsTable("`d:b`.`t:a`") }.getMessage - assert(message.contains("is not a valid name for metastore")) + assert(message.contains("Database 'd:b' not found")) } { val message = intercept[AnalysisException] { df.write.format("parquet").saveAsTable("`d:b`.`table`") }.getMessage - assert(message.contains("is not a valid name for metastore")) + assert(message.contains("Database 'd:b' not found")) } - withTempPath { dir => + withTempDir { dir => val path = dir.getCanonicalPath { @@ -293,7 +293,8 @@ class MultiDatabaseSuite extends QueryTest with SQLTestUtils with TestHiveSingle |) """.stripMargin) }.getMessage - assert(message.contains("is not a valid name for metastore")) + assert(message.contains("`t:a` is not a valid name for tables/databases. " + + "Valid names only contain alphabet characters, numbers and _.")) } { @@ -307,7 +308,7 @@ class MultiDatabaseSuite extends QueryTest with SQLTestUtils with TestHiveSingle |) """.stripMargin) }.getMessage - assert(message.contains("is not a valid name for metastore")) + assert(message.contains("Database 'd:b' not found")) } } } |