added test case

apache · Feb 6, 2015 · bd8d9f8 · bd8d9f8
1 parent 97bb90b
commit bd8d9f8
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala
@@ -27,6 +27,8 @@ import scala.util.Try
 import org.apache.hadoop.hive.conf.HiveConf.ConfVars
 
 import org.apache.spark.{SparkFiles, SparkException}
+import org.apache.spark.sql.catalyst.errors.TreeNodeException
+import org.apache.spark.sql.catalyst.expressions.Cast
 import org.apache.spark.sql.{DataFrame, Row}
 import org.apache.spark.sql.catalyst.plans.logical.Project
 import org.apache.spark.sql.Dsl._
@@ -59,13 +61,19 @@ class HiveQuerySuite extends HiveComparisonTest with BeforeAndAfter {
     Locale.setDefault(originalLocale)
   }
 
-  test("SPARK-4908: concurent hive native commands") {
+  test("SPARK-4908: concurrent hive native commands") {
     (1 to 100).par.map { _ =>
       sql("USE default")
       sql("SHOW TABLES")
     }
   }
 
+  test("SPARK-5649: added a rule to check datatypes cast") {
+    intercept[TreeNodeException[Cast]] {
+      sql("select cast(key as binary) from src").collect()
+    }
+  }
+
   createQueryTest("! operator",
     """
       |SELECT a FROM (