Skip to content
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

Spark: Fatal exception filtering QueryExecutionListener adapter #50

Closed
wajda opened this issue Jan 27, 2021 · 0 comments · Fixed by #51
Closed

Spark: Fatal exception filtering QueryExecutionListener adapter #50

wajda opened this issue Jan 27, 2021 · 0 comments · Fixed by #51
Assignees
Labels
enhancement New feature or request

Comments

@wajda
Copy link
Contributor

wajda commented Jan 27, 2021

Since Spark 2.4.6 a passed exception can be a wrapper on top of an Error.
https://issues.apache.org/jira/browse/SPARK-31144

Problem

In order to maintain consistent behavior of the QueryExecutionListener.onFailure() method in different Spark versions, and to avoid unintentional fatal errors processing additional check should be placed in all custom listener implementations.

Solution

Create an adapter trait that can be mixed-in with a QueryExecutionListener filtering out calls that carry wrapped fatal exceptions (either directly or wrapped ones).

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request
Projects
None yet
Development

Successfully merging a pull request may close this issue.

1 participant