aboutsummaryrefslogtreecommitdiff
path: root/sql
diff options
context:
space:
mode:
authorPatrick Wendell <pwendell@gmail.com>2014-07-09 19:44:24 -0700
committerPatrick Wendell <pwendell@gmail.com>2014-07-09 19:44:24 -0700
commit553c578de1a73a605197c184fc028efcc8dff010 (patch)
tree30331d22edc4d3af2b6587072f33604dbe95d4ec /sql
parentdd22bc2d570c54ad9853234d7a3f61720d606f39 (diff)
downloadspark-553c578de1a73a605197c184fc028efcc8dff010.tar.gz
spark-553c578de1a73a605197c184fc028efcc8dff010.tar.bz2
spark-553c578de1a73a605197c184fc028efcc8dff010.zip
HOTFIX: Remove persistently failing test in master.
Apparently this functionality is going to be removed soon anywyas.
Diffstat (limited to 'sql')
-rw-r--r--sql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala28
1 files changed, 0 insertions, 28 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala
index 3d7d5eedbe..e17ecc87fd 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala
@@ -36,34 +36,6 @@ class JoinSuite extends QueryTest {
assert(planned.size === 1)
}
- test("plans broadcast hash join, given hints") {
-
- def mkTest(buildSide: BuildSide, leftTable: String, rightTable: String) = {
- TestSQLContext.set("spark.sql.join.broadcastTables",
- s"${if (buildSide == BuildRight) rightTable else leftTable}")
- val rdd = sql(s"""SELECT * FROM $leftTable JOIN $rightTable ON key = a""")
- // Using `sparkPlan` because for relevant patterns in HashJoin to be
- // matched, other strategies need to be applied.
- val physical = rdd.queryExecution.sparkPlan
- val bhj = physical.collect { case j: BroadcastHashJoin if j.buildSide == buildSide => j }
-
- assert(bhj.size === 1, "planner does not pick up hint to generate broadcast hash join")
- checkAnswer(
- rdd,
- Seq(
- (1, "1", 1, 1),
- (1, "1", 1, 2),
- (2, "2", 2, 1),
- (2, "2", 2, 2),
- (3, "3", 3, 1),
- (3, "3", 3, 2)
- ))
- }
-
- mkTest(BuildRight, "testData", "testData2")
- mkTest(BuildLeft, "testData", "testData2")
- }
-
test("multiple-key equi-join is hash-join") {
val x = testData2.as('x)
val y = testData2.as('y)