diff options
author | Michael Armbrust <michael@databricks.com> | 2014-10-24 18:36:35 -0700 |
---|---|---|
committer | Josh Rosen <joshrosen@databricks.com> | 2014-10-24 18:36:35 -0700 |
commit | 3a845d3c048eebb0bddb3937128746fde3e8e4d8 (patch) | |
tree | 192dbba101a08ff02de979efba297587f30fd721 /sql/hive/v0.13.1 | |
parent | 898b22ab1fe90e8a3935b19566465046f2256fa6 (diff) | |
download | spark-3a845d3c048eebb0bddb3937128746fde3e8e4d8.tar.gz spark-3a845d3c048eebb0bddb3937128746fde3e8e4d8.tar.bz2 spark-3a845d3c048eebb0bddb3937128746fde3e8e4d8.zip |
[SQL] Update Hive test harness for Hive 12 and 13
As part of the upgrade I also copy the newest version of the query tests, and whitelist a bunch of new ones that are now passing.
Author: Michael Armbrust <michael@databricks.com>
Closes #2936 from marmbrus/fix13tests and squashes the following commits:
d9cbdab [Michael Armbrust] Remove user specific tests
65801cd [Michael Armbrust] style and rat
8f6b09a [Michael Armbrust] Update test harness to work with both Hive 12 and 13.
f044843 [Michael Armbrust] Update Hive query tests and golden files to 0.13
Diffstat (limited to 'sql/hive/v0.13.1')
-rw-r--r-- | sql/hive/v0.13.1/src/main/scala/org/apache/spark/sql/hive/Shim13.scala (renamed from sql/hive/v0.13.1/src/main/scala/org/apache/spark/sql/hive/Shim.scala) | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/sql/hive/v0.13.1/src/main/scala/org/apache/spark/sql/hive/Shim.scala b/sql/hive/v0.13.1/src/main/scala/org/apache/spark/sql/hive/Shim13.scala index 8678c0c475..b8d893d8c1 100644 --- a/sql/hive/v0.13.1/src/main/scala/org/apache/spark/sql/hive/Shim.scala +++ b/sql/hive/v0.13.1/src/main/scala/org/apache/spark/sql/hive/Shim13.scala @@ -72,9 +72,6 @@ private[hive] object HiveShim { context.runSqlHive("USE default") } - /* The string used to denote an empty comments field in the schema. */ - def getEmptyCommentsFieldValue = "" - def getCommandProcessor(cmd: Array[String], conf: HiveConf) = { CommandProcessorFactory.get(cmd, conf) } @@ -122,6 +119,8 @@ private[hive] object HiveShim { def getAllPartitionsOf(client: Hive, tbl: Table) = client.getAllPartitionsOf(tbl) + def compatibilityBlackList = Seq() + /* * Bug introdiced in hive-0.13. FileSinkDesc is serializable, but its member path is not. * Fix it through wrapper. |