Skip to content

Commit 5b2b272

Browse files
committed
Fix
1 parent 59e60d4 commit 5b2b272

File tree

1 file changed

+24
-6
lines changed

1 file changed

+24
-6
lines changed

sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/analysis/ResolveHintsSuite.scala

Lines changed: 24 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -161,28 +161,46 @@ class ResolveHintsSuite extends AnalysisTest {
161161
checkAnalysis(
162162
UnresolvedHint("MAPJOIN", Seq("table", "table2"),
163163
table("table").join(table("table2"))),
164-
Join(ResolvedHint(testRelation, HintInfo(broadcast = true)),
165-
ResolvedHint(testRelation2, HintInfo(broadcast = true)), Inner, None),
164+
Join(
165+
ResolvedHint(testRelation, HintInfo(broadcast = true)),
166+
ResolvedHint(testRelation2, HintInfo(broadcast = true)),
167+
Inner,
168+
None,
169+
JoinHint(None, None)),
166170
caseSensitive = false)
167171

168172
checkAnalysis(
169173
UnresolvedHint("MAPJOIN", Seq("TaBlE", "table2"),
170174
table("TaBlE").join(table("TaBlE2"))),
171-
Join(ResolvedHint(testRelation, HintInfo(broadcast = true)), testRelation2, Inner, None),
175+
Join(
176+
ResolvedHint(testRelation, HintInfo(broadcast = true)),
177+
testRelation2,
178+
Inner,
179+
None,
180+
JoinHint(None, None)),
172181
caseSensitive = true)
173182

174183
// global temp table
175184
checkAnalysis(
176185
UnresolvedHint("MAPJOIN", Seq("global_temp.table4", "GlOBal_TeMP.table5"),
177186
table("global_temp", "table4").join(table("global_temp", "table5"))),
178-
Join(ResolvedHint(testRelation4, HintInfo(broadcast = true)),
179-
ResolvedHint(testRelation5, HintInfo(broadcast = true)), Inner, None),
187+
Join(
188+
ResolvedHint(testRelation4, HintInfo(broadcast = true)),
189+
ResolvedHint(testRelation5, HintInfo(broadcast = true)),
190+
Inner,
191+
None,
192+
JoinHint(None, None)),
180193
caseSensitive = false)
181194

182195
checkAnalysis(
183196
UnresolvedHint("MAPJOIN", Seq("global_temp.TaBlE4", "table5"),
184197
table("global_temp", "TaBlE4").join(table("global_temp", "TaBlE5"))),
185-
Join(ResolvedHint(testRelation4, HintInfo(broadcast = true)), testRelation5, Inner, None),
198+
Join(
199+
ResolvedHint(testRelation4, HintInfo(broadcast = true)),
200+
testRelation5,
201+
Inner,
202+
None,
203+
JoinHint(None, None)),
186204
caseSensitive = true)
187205
}
188206
}

0 commit comments

Comments
 (0)