diff options
author | Patrick Wendell <pwendell@gmail.com> | 2014-07-09 19:44:24 -0700 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2014-07-09 19:44:24 -0700 |
commit | 553c578de1a73a605197c184fc028efcc8dff010 (patch) | |
tree | 30331d22edc4d3af2b6587072f33604dbe95d4ec /sql | |
parent | dd22bc2d570c54ad9853234d7a3f61720d606f39 (diff) | |
download | spark-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.scala | 28 |
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) |