Spark History Server connector - polls and publishes jobs to NATS
Project description
spark-advisor-hs-connector
Spark History Server connector — fetches job data and publishes to NATS. Part of the spark-advisor ecosystem.
Install
pip install spark-advisor-hs-connector
What it does
Connects to Apache Spark History Server REST API to fetch job metrics, stage details, executor info, and configuration. Operates in two modes:
- On-demand — NATS subscriber for
job.fetchrequests (returnsJobAnalysis) - Background polling — periodically scans History Server for new applications and publishes them to NATS
History Server endpoints used
GET /api/v1/applications/{app-id}— app metadataGET /api/v1/applications/{app-id}/environment— spark.* configGET /api/v1/applications/{app-id}/stages— stage metricsGET /api/v1/applications/{app-id}/stages/{id}/{attempt}/taskSummary— task distributionGET /api/v1/applications/{app-id}/executors— executor metrics
Deployment
export SA_CONNECTOR_HISTORY_SERVER_URL=http://yarn:18080
export SA_CONNECTOR_NATS__URL=nats://localhost:4222
spark-advisor-hs-connector
Configuration
| Variable | Default | Description |
|---|---|---|
SA_CONNECTOR_HISTORY_SERVER_URL |
http://localhost:18080 |
Spark History Server URL |
SA_CONNECTOR_NATS__URL |
nats://localhost:4222 |
NATS broker URL |
SA_CONNECTOR_POLL_INTERVAL_SECONDS |
60 |
Polling interval |
SA_CONNECTOR_BATCH_SIZE |
50 |
Apps per poll cycle |
SA_CONNECTOR_OTEL__ENABLED |
false |
Enable OpenTelemetry distributed tracing |
Links
License
Apache 2.0
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file spark_advisor_hs_connector-0.1.12.tar.gz.
File metadata
- Download URL: spark_advisor_hs_connector-0.1.12.tar.gz
- Upload date:
- Size: 14.8 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: uv/0.10.11 {"installer":{"name":"uv","version":"0.10.11","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
e1fec5ad210c4f257b36ffecfb5e821bb65a0bffadddf3cf77694b41d72cf100
|
|
| MD5 |
84b7082f6b6b36f6178fc41e4bbc43f2
|
|
| BLAKE2b-256 |
eefac95418fac698d68fba5edb3e3f0bf2d508be5621cdadc64a4969435d2efb
|
File details
Details for the file spark_advisor_hs_connector-0.1.12-py3-none-any.whl.
File metadata
- Download URL: spark_advisor_hs_connector-0.1.12-py3-none-any.whl
- Upload date:
- Size: 13.2 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: uv/0.10.11 {"installer":{"name":"uv","version":"0.10.11","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
026742d269bc4d7691a00560d777e8c8862bdaf06b433efacb95c32bbea787a6
|
|
| MD5 |
95863db4394f1e9f7c83080d94661257
|
|
| BLAKE2b-256 |
430f79c970976737bd7adc4a7bf1e0a672ceac3a4beade5904f92c73eb3f6287
|
