-
Notifications
You must be signed in to change notification settings - Fork 29k
[SPARK-54685][SQL][CONNECT] Remove redundant observed-metrics responses #53445
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
|
@heyihong can you please do this the other way around and remove the dependency on Observation in ExecuteThreadRunner. |
allisonwang-db
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.
cc @ueshin
@hvanhovell Yes, I am working on that. This pull request is a code cleanup and is orthogonal to your ask if I understand correctly. This piece of code can be removed even if we remove the dependency on Observation in ExecuteThreadRunner. |
allisonwang-db
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.
cc @ueshin
|
Merged to master. |
|
@heyihong @HyukjinKwon, can you check the JIRA-ID which seems to be wrong? |
|
@yaooqinn Good catch — this is the right JIRA ticket: https://issues.apache.org/jira/browse/SPARK-54685 |
What changes were proposed in this pull request?
This PR removes the observed metrics response generation from SparkConnectPlanExecution in Spark Connect server since creating the observed metrics response in ExecuteThreadRunner is sufficient.
Changes:
Why are the changes needed?
The createObservedMetricsResponse() method is being removed because:
Does this PR introduce any user-facing change?
No. Since the method always returns an empty response due to the observation registration requirement, removing it has no functional impact on users.
How was this patch tested?
build/sbt "connect-client-jvm/testOnly *ClientE2ETestSuiteWas this patch authored or co-authored using generative AI tooling?
Generated-by: Cursor 2.1.47