-
Notifications
You must be signed in to change notification settings - Fork 28.5k
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-35062][SQL] Group exception messages in sql/streaming #32464
Conversation
Test build #138232 has finished for PR 32464 at commit
|
Kubernetes integration test unable to build dist. exiting with code: 1 |
Kubernetes integration test starting |
Kubernetes integration test status failure |
Test build #138235 has finished for PR 32464 at commit
|
Test build #138249 has finished for PR 32464 at commit
|
Kubernetes integration test unable to build dist. exiting with code: 1 |
Test build #138277 has finished for PR 32464 at commit
|
Kubernetes integration test unable to build dist. exiting with code: 1 |
Kubernetes integration test starting |
Kubernetes integration test status failure |
Test build #138278 has finished for PR 32464 at commit
|
ping @allisonwang-db |
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.
Looks good! There are two more exceptions under streaming/ui
. How about adding them in the same PR?
'sql/core/src/main/scala/org/apache/spark/sql/streaming/ui'
Filename | Count |
---|---|
StreamingQueryPage.scala | 1 |
StreamingQueryStatisticsPage.scala | 1 |
@@ -1391,4 +1391,58 @@ private[spark] object QueryCompilationErrors { | |||
def functionUnsupportedInV2CatalogError(): Throwable = { | |||
new AnalysisException("function is only supported in v1 catalog") | |||
} | |||
|
|||
def operateHiveDataSourceDirectlyError(operation: String): Throwable = { |
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.
How about cannotOperateOnHiveDataSourceError
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.
How about cannotOperateOnHiveDataSourceFilesError
?
I checked the two file and found all the errors is assert-like Exception. According to the discussion between @cloud-fan and me, we not need to treat the assert-like Exception. |
Kubernetes integration test starting |
Kubernetes integration test status failure |
Test build #138352 has finished for PR 32464 at commit
|
retest this please |
Kubernetes integration test starting |
Kubernetes integration test status failure |
Test build #138361 has finished for PR 32464 at commit
|
ping @allisonwang-db |
cc @cloud-fan |
thanks, merging to master! |
@allisonwang-db Thanks for you review. @cloud-fan Thank you too. |
What changes were proposed in this pull request?
This PR group exception messages in
sql/core/src/main/scala/org/apache/spark/sql/streaming
.Why are the changes needed?
It will largely help with standardization of error messages and its maintenance.
Does this PR introduce any user-facing change?
No. Error messages remain unchanged.
How was this patch tested?
No new tests - pass all original tests to make sure it doesn't break any existing behavior.