-
Notifications
You must be signed in to change notification settings - Fork 29k
[SPARK-41217][SQL] Add the error class FAILED_FUNCTION_CALL
#38744
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.
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
Conversation
FAILED_FUNCTION_CALLFAILED_FUNCTION_CALL
|
@panbingkun @LuciferYang @itholic @cloud-fan @srielau Could you review this PR, please. |
|
|
||
| def funcBuildError(funcName: String, cause: Exception): Throwable = { | ||
| cause.getCause match { | ||
| case st: SparkThrowable with Throwable => st |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
If some Spark's exception happens during preparation of a function call, we just propagate it to users AS IS otherwise (something we didn't catch) we wrap it by AnalysisException(errorClass = FAILED_FUNCTION_CALL)
|
@panbingkun @LuciferYang Your PRs are related to this one. I would propose to merge this first of all to properly propagate
@cloud-fan We bypass |
LuciferYang
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
+1, LGTM
I think we can merge this as soon as possible
|
+1, LGTM |
|
Merging to master. Thank you, @panbingkun @LuciferYang @cloud-fan for review. |
|
OK, I will rebase my pr |
|
@panbingkun Please, update your PRs. |
### What changes were proposed in this pull request? In the PR, I propose new error class `FAILED_FUNCTION_CALL` for errors that might occur while preparing functions class, for instance during creation of expression instances. Also, the PR propagates `SparkThrowable` to users in handling any exceptions coming from preparations of functions calls. ### Why are the changes needed? To improve user experience with Spark SQL, in particular, the PR makes errors more clear. ### Does this PR introduce _any_ user-facing change? Yes, it affects the user-facing errors. ### How was this patch tested? By running the modified test suites: ``` $ build/sbt "core/testOnly *SparkThrowableSuite" $ PYSPARK_PYTHON=python3 build/sbt "sql/testOnly org.apache.spark.sql.SQLQueryTestSuite" ``` Closes apache#38744 from MaxGekk/failed-builtin-func. Authored-by: Max Gekk <[email protected]> Signed-off-by: Max Gekk <[email protected]>
### What changes were proposed in this pull request? In the PR, I propose new error class `FAILED_FUNCTION_CALL` for errors that might occur while preparing functions class, for instance during creation of expression instances. Also, the PR propagates `SparkThrowable` to users in handling any exceptions coming from preparations of functions calls. ### Why are the changes needed? To improve user experience with Spark SQL, in particular, the PR makes errors more clear. ### Does this PR introduce _any_ user-facing change? Yes, it affects the user-facing errors. ### How was this patch tested? By running the modified test suites: ``` $ build/sbt "core/testOnly *SparkThrowableSuite" $ PYSPARK_PYTHON=python3 build/sbt "sql/testOnly org.apache.spark.sql.SQLQueryTestSuite" ``` Closes apache#38744 from MaxGekk/failed-builtin-func. Authored-by: Max Gekk <[email protected]> Signed-off-by: Max Gekk <[email protected]>
### What changes were proposed in this pull request? In the PR, I propose new error class `FAILED_FUNCTION_CALL` for errors that might occur while preparing functions class, for instance during creation of expression instances. Also, the PR propagates `SparkThrowable` to users in handling any exceptions coming from preparations of functions calls. ### Why are the changes needed? To improve user experience with Spark SQL, in particular, the PR makes errors more clear. ### Does this PR introduce _any_ user-facing change? Yes, it affects the user-facing errors. ### How was this patch tested? By running the modified test suites: ``` $ build/sbt "core/testOnly *SparkThrowableSuite" $ PYSPARK_PYTHON=python3 build/sbt "sql/testOnly org.apache.spark.sql.SQLQueryTestSuite" ``` Closes apache#38744 from MaxGekk/failed-builtin-func. Authored-by: Max Gekk <[email protected]> Signed-off-by: Max Gekk <[email protected]>
What changes were proposed in this pull request?
In the PR, I propose new error class
FAILED_FUNCTION_CALLfor errors that might occur while preparing functions class, for instance during creation of expression instances. Also, the PR propagatesSparkThrowableto users in handling any exceptions coming from preparations of functions calls.Why are the changes needed?
To improve user experience with Spark SQL, in particular, the PR makes errors more clear.
Does this PR introduce any user-facing change?
Yes, it affects the user-facing errors.
How was this patch tested?
By running the modified test suites: