Skip to content

Commit c7a4373

Browse files
committed
Addressed @concretevitamin's comment
1 parent 784940b commit c7a4373

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -373,7 +373,7 @@ class HiveQuerySuite extends HiveComparisonTest {
373373
test("SPARK-2263: Insert Map<K, V> values") {
374374
hql("CREATE TABLE m(value MAP<INT, STRING>)")
375375
hql("INSERT OVERWRITE TABLE m SELECT MAP(key, value) FROM src LIMIT 10")
376-
hql("SELECT * FROM m").zip(hql("SELECT * FROM src LIMIT 10")).map {
376+
hql("SELECT * FROM m").collect().zip(hql("SELECT * FROM src LIMIT 10").collect()).map {
377377
case (Row(map: Map[Int, String]), Row(key: Int, value: String)) =>
378378
assert(map.size === 1)
379379
assert(map.head === (key, value))

0 commit comments

Comments
 (0)