aboutsummaryrefslogtreecommitdiff
path: root/sql
diff options
context:
space:
mode:
authorviirya <viirya@gmail.com>2014-08-27 14:55:05 -0700
committerMichael Armbrust <michael@databricks.com>2014-08-27 14:55:05 -0700
commit28d41d627919fcb196d9d31bad65d664770bee67 (patch)
tree91910ebb4f7666ec60aca624692989ec74451850 /sql
parent63a053ab140d7bf605e8c5b7fb5a7bd52aca29b2 (diff)
downloadspark-28d41d627919fcb196d9d31bad65d664770bee67.tar.gz
spark-28d41d627919fcb196d9d31bad65d664770bee67.tar.bz2
spark-28d41d627919fcb196d9d31bad65d664770bee67.zip
[SPARK-3252][SQL] Add missing condition for test
According to the text message, both relations should be tested. So add the missing condition. Author: viirya <viirya@gmail.com> Closes #2159 from viirya/fix_test and squashes the following commits: b1c0f52 [viirya] add missing condition.
Diffstat (limited to 'sql')
-rw-r--r--sql/hive/src/test/scala/org/apache/spark/sql/hive/StatisticsSuite.scala3
1 files changed, 2 insertions, 1 deletions
diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/StatisticsSuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/StatisticsSuite.scala
index 8d6ca9939a..a35c40efdc 100644
--- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/StatisticsSuite.scala
+++ b/sql/hive/src/test/scala/org/apache/spark/sql/hive/StatisticsSuite.scala
@@ -150,7 +150,8 @@ class StatisticsSuite extends QueryTest with BeforeAndAfterAll {
val sizes = rdd.queryExecution.analyzed.collect {
case r if ct.runtimeClass.isAssignableFrom(r.getClass) => r.statistics.sizeInBytes
}
- assert(sizes.size === 2 && sizes(0) <= autoBroadcastJoinThreshold,
+ assert(sizes.size === 2 && sizes(0) <= autoBroadcastJoinThreshold
+ && sizes(1) <= autoBroadcastJoinThreshold,
s"query should contain two relations, each of which has size smaller than autoConvertSize")
// Using `sparkPlan` because for relevant patterns in HashJoin to be