You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2016/01/03 20:09:33 UTC
spark git commit: [SPARK-12533][SQL] hiveContext.table() throws the
wrong exception
Repository: spark
Updated Branches:
refs/heads/master c3d505602 -> c82924d56
[SPARK-12533][SQL] hiveContext.table() throws the wrong exception
Avoiding the the No such table exception and throwing analysis exception as per the bug: SPARK-12533
Author: thomastechs <th...@tcs.com>
Closes #10529 from thomastechs/topic-branch.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/c82924d5
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/c82924d5
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/c82924d5
Branch: refs/heads/master
Commit: c82924d564c07e6e6f635b9e263994dedf06268a
Parents: c3d5056
Author: thomastechs <th...@tcs.com>
Authored: Sun Jan 3 11:09:30 2016 -0800
Committer: Reynold Xin <rx...@databricks.com>
Committed: Sun Jan 3 11:09:30 2016 -0800
----------------------------------------------------------------------
.../scala/org/apache/spark/sql/catalyst/analysis/Catalog.scala | 2 +-
.../src/test/scala/org/apache/spark/sql/CachedTableSuite.scala | 6 +++---
2 files changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/c82924d5/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Catalog.scala
----------------------------------------------------------------------
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Catalog.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Catalog.scala
index 8f4ce74..3b775c3 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Catalog.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Catalog.scala
@@ -104,7 +104,7 @@ class SimpleCatalog(val conf: CatalystConf) extends Catalog {
val tableName = getTableName(tableIdent)
val table = tables.get(tableName)
if (table == null) {
- throw new NoSuchTableException
+ throw new AnalysisException("Table not found: " + tableName)
}
val tableWithQualifiers = Subquery(tableName, table)
http://git-wip-us.apache.org/repos/asf/spark/blob/c82924d5/sql/core/src/test/scala/org/apache/spark/sql/CachedTableSuite.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/CachedTableSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/CachedTableSuite.scala
index d86df4c..6b735bc 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/CachedTableSuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/CachedTableSuite.scala
@@ -17,7 +17,7 @@
package org.apache.spark.sql
-import org.apache.spark.sql.catalyst.analysis.NoSuchTableException
+
import org.apache.spark.sql.execution.Exchange
import org.apache.spark.sql.execution.PhysicalRDD
@@ -289,7 +289,7 @@ class CachedTableSuite extends QueryTest with SQLTestUtils with SharedSQLContext
testData.select('key).registerTempTable("t1")
sqlContext.table("t1")
sqlContext.dropTempTable("t1")
- intercept[NoSuchTableException](sqlContext.table("t1"))
+ intercept[AnalysisException](sqlContext.table("t1"))
}
test("Drops cached temporary table") {
@@ -301,7 +301,7 @@ class CachedTableSuite extends QueryTest with SQLTestUtils with SharedSQLContext
assert(sqlContext.isCached("t2"))
sqlContext.dropTempTable("t1")
- intercept[NoSuchTableException](sqlContext.table("t1"))
+ intercept[AnalysisException](sqlContext.table("t1"))
assert(!sqlContext.isCached("t2"))
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org