Skip to content
Snippets Groups Projects
Commit 12c7635d authored by Forest Fang's avatar Forest Fang Committed by Andrew Or
Browse files

[MINOR] Fix typo in AggregationQuerySuite.scala

Author: Forest Fang <saurfang@users.noreply.github.com>

Closes #9357 from saurfang/patch-1.
parent 6600786d
No related branches found
No related tags found
No related merge requests found
......@@ -795,14 +795,14 @@ abstract class AggregationQuerySuite extends QueryTest with SQLTestUtils with Te
val df = sqlContext.createDataFrame(rdd, schema)
val allColumns = df.schema.fields.map(f => col(f.name))
val expectedAnaswer =
val expectedAnswer =
data
.find(r => r.getInt(0) == 50)
.getOrElse(fail("A row with id 50 should be the expected answer."))
checkAnswer(
df.groupBy().agg(udaf(allColumns: _*)),
// udaf returns a Row as the output value.
Row(expectedAnaswer)
Row(expectedAnswer)
)
}
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment