Skip to content

[SPARK-24951][SQL] Table valued functions should throw AnalysisException #21934

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
rxin wants to merge 2 commits into from
Closed

[SPARK-24951][SQL] Table valued functions should throw AnalysisException #21934

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
08a6b7f
[SPARK-24951][SQL] Table valued functions should throw AnalysisException
rxin Jul 31, 2018
514fd77
Improve error message
rxin Jul 31, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
[SPARK-24951][SQL] Table valued functions should throw AnalysisException
  • Loading branch information
@rxin
rxin committed Jul 31, 2018
commit 08a6b7fc1d2a1a6149c4da2ca1657258347fd18f
4 changes: 2 additions & 2 deletions ...t/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveTableValuedFunctions.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -68,9 +68,9 @@ object ResolveTableValuedFunctions extends Rule[LogicalPlan] {
: (ArgumentList, Seq[Any] => LogicalPlan) = {
(ArgumentList(args: _*),
pf orElse {
case args =>
case arguments =>
throw new IllegalArgumentException(
"Invalid arguments for resolved function: " + args.mkString(", "))
"Invalid arguments for resolved function: " + arguments.mkString(", "))
})
}

Expand Down
2 changes: 1 addition & 1 deletion sql/core/src/test/resources/sql-tests/results/table-valued-functions.sql.out
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ select * from range(1, null)
-- !query 6 schema
struct<>
-- !query 6 output
java.lang.IllegalArgumentException
org.apache.spark.sql.AnalysisException
Invalid arguments for resolved function: 1, null


Expand Down