Repository: spark
Updated Branches:
  refs/heads/branch-1.1 c1ffa3e4c -> b3d763b0b


[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 <[email protected]>

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 <[email protected]>


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/b3d763b0
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/b3d763b0
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/b3d763b0

Branch: refs/heads/branch-1.1
Commit: b3d763b0b7fc6345dac5d222414f902e4afdee13
Parents: c1ffa3e
Author: viirya <[email protected]>
Authored: Wed Aug 27 14:55:05 2014 -0700
Committer: Michael Armbrust <[email protected]>
Committed: Wed Aug 27 15:04:35 2014 -0700

----------------------------------------------------------------------
 .../test/scala/org/apache/spark/sql/hive/StatisticsSuite.scala    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/b3d763b0/sql/hive/src/test/scala/org/apache/spark/sql/hive/StatisticsSuite.scala
----------------------------------------------------------------------
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 8d6ca99..a35c40e 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


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to