aboutsummaryrefslogtreecommitdiff
path: root/sql/hive/compatibility/src/test/scala
diff options
context:
space:
mode:
authorReynold Xin <rxin@databricks.com>2015-07-28 17:42:35 -0700
committerReynold Xin <rxin@databricks.com>2015-07-28 17:42:35 -0700
commit6662ee21244067180c1bcef0b16107b2979fd933 (patch)
treec99d004dd3a4cb2309e2f39537907e1859e54d4e /sql/hive/compatibility/src/test/scala
parentb7f54119f86f916481aeccc67f07e77dc2a924c7 (diff)
downloadspark-6662ee21244067180c1bcef0b16107b2979fd933.tar.gz
spark-6662ee21244067180c1bcef0b16107b2979fd933.tar.bz2
spark-6662ee21244067180c1bcef0b16107b2979fd933.zip
[SPARK-9418][SQL] Use sort-merge join as the default shuffle join.
Sort-merge join is more robust in Spark since sorting can be made using the Tungsten sort operator. Author: Reynold Xin <rxin@databricks.com> Closes #7733 from rxin/smj and squashes the following commits: 61e4d34 [Reynold Xin] Fixed test case. 5ffd731 [Reynold Xin] Fixed JoinSuite. a137dc0 [Reynold Xin] [SPARK-9418][SQL] Use sort-merge join as the default shuffle join.
Diffstat (limited to 'sql/hive/compatibility/src/test/scala')
-rw-r--r--sql/hive/compatibility/src/test/scala/org/apache/spark/sql/hive/execution/HashJoinCompatibilitySuite.scala (renamed from sql/hive/compatibility/src/test/scala/org/apache/spark/sql/hive/execution/SortMergeCompatibilitySuite.scala)8
1 files changed, 4 insertions, 4 deletions
diff --git a/sql/hive/compatibility/src/test/scala/org/apache/spark/sql/hive/execution/SortMergeCompatibilitySuite.scala b/sql/hive/compatibility/src/test/scala/org/apache/spark/sql/hive/execution/HashJoinCompatibilitySuite.scala
index 1fe4fe9629..1a5ba20404 100644
--- a/sql/hive/compatibility/src/test/scala/org/apache/spark/sql/hive/execution/SortMergeCompatibilitySuite.scala
+++ b/sql/hive/compatibility/src/test/scala/org/apache/spark/sql/hive/execution/HashJoinCompatibilitySuite.scala
@@ -23,16 +23,16 @@ import org.apache.spark.sql.SQLConf
import org.apache.spark.sql.hive.test.TestHive
/**
- * Runs the test cases that are included in the hive distribution with sort merge join is true.
+ * Runs the test cases that are included in the hive distribution with hash joins.
*/
-class SortMergeCompatibilitySuite extends HiveCompatibilitySuite {
+class HashJoinCompatibilitySuite extends HiveCompatibilitySuite {
override def beforeAll() {
super.beforeAll()
- TestHive.setConf(SQLConf.SORTMERGE_JOIN, true)
+ TestHive.setConf(SQLConf.SORTMERGE_JOIN, false)
}
override def afterAll() {
- TestHive.setConf(SQLConf.SORTMERGE_JOIN, false)
+ TestHive.setConf(SQLConf.SORTMERGE_JOIN, true)
super.afterAll()
}