We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 225e250 commit 985834bCopy full SHA for 985834b
sql/core/src/test/scala/org/apache/spark/sql/execution/joins/BroadcastJoinSuite.scala
@@ -474,7 +474,7 @@ abstract class BroadcastJoinSuiteBase extends QueryTest with SQLTestUtils
474
val t1 = spark.table("t1")
475
val t3 = spark.table("t3")
476
477
- // join2 is a broadcast join where df2 is broadcasted. Note that output partitioning on the
+ // join1 is a broadcast join where df2 is broadcasted. Note that output partitioning on the
478
// streamed side (t1) is HashPartitioning (bucketed files).
479
val join1 = t1.join(df2, t1("i1") === df2("i2"))
480
val plan1 = join1.queryExecution.executedPlan
0 commit comments