Skip to content

Commit b8b87e1

Browse files
committed
Fixed DataFrameJoinSuite.
1 parent d910141 commit b8b87e1

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

sql/core/src/test/scala/org/apache/spark/sql/DataFrameJoinSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,8 +77,8 @@ class DataFrameJoinSuite extends QueryTest {
7777
df.join(df, df("key") === df("key") && df("value") === 1),
7878
Row(1, "1", 1, "1") :: Nil)
7979

80-
val left = df.groupBy("key").agg($"key", count("*"))
81-
val right = df.groupBy("key").agg($"key", sum("key"))
80+
val left = df.groupBy("key").agg(count("*"))
81+
val right = df.groupBy("key").agg(sum("key"))
8282
checkAnswer(
8383
left.join(right, left("key") === right("key")),
8484
Row(1, 1, 1, 1) :: Row(2, 1, 2, 2) :: Nil)

0 commit comments

Comments
 (0)