aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorBurak Yavuz <brkyvz@gmail.com>2015-06-29 18:48:28 -0700
committerYin Huai <yhuai@databricks.com>2015-06-29 18:48:38 -0700
commitffc793a6caaf8e6190651af4ff2d46492f062fc0 (patch)
tree02c83c8b1939d6a06fd920e32ea975744f618f96
parent80d53565ae951f7ef0626ad2ad0e2ecb55993a21 (diff)
downloadspark-ffc793a6caaf8e6190651af4ff2d46492f062fc0.tar.gz
spark-ffc793a6caaf8e6190651af4ff2d46492f062fc0.tar.bz2
spark-ffc793a6caaf8e6190651af4ff2d46492f062fc0.zip
[SPARK-8715] ArrayOutOfBoundsException fixed for DataFrameStatSuite.crosstab
cc yhuai Author: Burak Yavuz <brkyvz@gmail.com> Closes #7100 from brkyvz/ct-flakiness-fix and squashes the following commits: abc299a [Burak Yavuz] change 'to' to until 7e96d7c [Burak Yavuz] ArrayOutOfBoundsException fixed for DataFrameStatSuite.crosstab (cherry picked from commit ecacb1e88a135c802e253793e7c863d6ca8d2408) Signed-off-by: Yin Huai <yhuai@databricks.com>
-rw-r--r--sql/core/src/test/scala/org/apache/spark/sql/DataFrameStatSuite.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/DataFrameStatSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/DataFrameStatSuite.scala
index f740fb2274..3e87ebad08 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/DataFrameStatSuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/DataFrameStatSuite.scala
@@ -78,7 +78,7 @@ class DataFrameStatSuite extends SparkFunSuite {
val rows = crosstab.collect()
rows.foreach { row =>
val i = row.getString(0).toInt
- for (col <- 1 to 9) {
+ for (col <- 1 until columnNames.length) {
val j = columnNames(col).toInt
assert(row.getLong(col) === expected.getOrElse((i, j), 0).toLong)
}