diff options
author | viirya <viirya@gmail.com> | 2014-08-27 14:55:05 -0700 |
---|---|---|
committer | Michael Armbrust <michael@databricks.com> | 2014-08-27 15:04:35 -0700 |
commit | b3d763b0b7fc6345dac5d222414f902e4afdee13 (patch) | |
tree | 454d89d113d44dc4679f23025b24f5c3781aa4c8 /sql/hive/src | |
parent | c1ffa3e4cdfbd1f84b5c8d8de5d0fb958a19e211 (diff) | |
download | spark-b3d763b0b7fc6345dac5d222414f902e4afdee13.tar.gz spark-b3d763b0b7fc6345dac5d222414f902e4afdee13.tar.bz2 spark-b3d763b0b7fc6345dac5d222414f902e4afdee13.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.
(cherry picked from commit 28d41d627919fcb196d9d31bad65d664770bee67)
Signed-off-by: Michael Armbrust <michael@databricks.com>
Diffstat (limited to 'sql/hive/src')
-rw-r--r-- | sql/hive/src/test/scala/org/apache/spark/sql/hive/StatisticsSuite.scala | 3 |
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 |