rangadi opened a new pull request, #40342:
URL: https://github.com/apache/spark/pull/40342
### What changes were proposed in this pull request?
This adds an gRPC interceptor in spark-connect server. It logs all the
incoming RPC requests and responses.
- How to enable: Set interceptor config. e.g.
./sbin/start-connect-server.sh --conf
spark.connect.grpc.interceptor.classes=org.apache.spark.sql.connect.service.LoggingInterceptor
--jars connector/connect/server/target/spark-connect_*-SNAPSHOT.jar
- Sample output:
23/03/08 10:54:37 INFO LoggingInterceptor: Received RPC Request
spark.connect.SparkConnectService/ExecutePlan (id 1868663481):
{
"client_id": "6844bc44-4411-4481-8109-a10e3a836f97",
"user_context": {
"user_id": "raghu"
},
"plan": {
"root": {
"common": {
"plan_id": "37"
},
"show_string": {
"input": {
"common": {
"plan_id": "36"
},
"read": {
"data_source": {
"format": "csv",
"schema": "",
"paths": ["file:///tmp/x-in"]
}
}
},
"num_rows": 20,
"truncate": 20
}
}
},
"client_type": "_SPARK_CONNECT_PYTHON"
}
### Why are the changes needed?
This is useful in development. It might be useful to debug some problems in
production as well.
### Does this PR introduce _any_ user-facing change?
no
### How was this patch tested?
- Manually in development
- Unit test
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
