File tree Expand file tree Collapse file tree 1 file changed +6
-6
lines changed
sql/core/src/test/scala/org/apache/spark/sql Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -71,17 +71,17 @@ class JoinSuite extends QueryTest with SharedSQLContext {
7171 base.createOrReplaceTempView(" base" )
7272
7373 val dist1 = spark.sql("""
74- SELECT parent level1
75- FROM base INNER JOIN hier h1 ON base.id = h1.son
76- GROUP BY parent""" )
74+ SELECT parent level1
75+ FROM base INNER JOIN hier h1 ON base.id = h1.son
76+ GROUP BY parent""" )
7777
7878 dist1.createOrReplaceTempView(" dist1" )
7979 // dist1.count() // or put a count here
8080
8181 val dist2 = spark.sql("""
82- SELECT parent level2
83- FROM dist1 INNER JOIN hier h2 ON dist1.level1 = h2.son
84- GROUP BY parent""" )
82+ SELECT parent level2
83+ FROM dist1 INNER JOIN hier h2 ON dist1.level1 = h2.son
84+ GROUP BY parent""" )
8585
8686 val plan = dist2.queryExecution.executedPlan
8787 // For debug print tree string with partitioning suffix
You can’t perform that action at this time.
0 commit comments