Skip to content

Commit e060dea

Browse files
committed
address comments.
1 parent 4b65af3 commit e060dea

2 files changed

Lines changed: 2 additions & 3 deletions

File tree

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -406,7 +406,7 @@ class Analyzer(
406406
}
407407
)
408408
case g: Generate if containsStar(g.generator.children) =>
409-
failAnalysis("Cannot explode *, explode can only be applied on a specific column.")
409+
failAnalysis("Invalid usage of '*' in explode/json_tuple/UDTF")
410410
}
411411

412412
/**

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -178,8 +178,7 @@ class DataFrameSuite extends QueryTest with SharedSQLContext {
178178
csv.split(",").map(v => Tuple1(prefix + ":" + v)).toSeq
179179
}.queryExecution.assertAnalyzed()
180180
}
181-
assert(e.getMessage.contains(
182-
"Cannot explode *, explode can only be applied on a specific column."))
181+
assert(e.getMessage.contains("Invalid usage of '*' in explode/json_tuple/UDTF"))
183182

184183
df.explode('prefix, 'csv) { case Row(prefix: String, csv: String) =>
185184
csv.split(",").map(v => Tuple1(prefix + ":" + v)).toSeq

0 commit comments

Comments
 (0)