MCP Apache Spark History Server

Unclaimed

by kubeflow

MCP Server and CLI for Apache Spark History Server. Debug Spark applications from AI agents, scripts, or the terminal.

Install

$uvx --from mcp-apache-spark-history-server spark-mcp

Unclaimed listing

Is this your MCP server?

This listing was auto-indexed from the public record. Claim it to edit the page, set compatibility and unlock growth tools. Takes under two minutes.

Claim this server

Tools (19)

aws_analyze_spark_workload

One-shot root cause analysis of failed/slow Spark workloads

aws_spark_code_recommendation

Code fix recommendations for identified Spark issues

compare_job_environments

Diff Spark configs between two applications

compare_job_performance

Diff performance metrics between two applications

compare_sql_executions

Compare aggregated performance metrics (stages, tasks, shuffle, spill, GC) between two SQL executions; opt-in plan-structure diff

compare_stages

Compare two stages (optionally across applications): stage metrics and per-task p25/p50/p75/max quantiles

get_environment

Spark config, JVM info, system properties, classpath; optional section filter to return a single part

get_executor_summary

Aggregate metrics across all executors

get_executor_thread_dump

JVM thread dump for a driver/executor, with state/name/blocked filters (running apps only)

get_job_bottlenecks

Identify bottlenecks across stages, tasks, and executors

get_resource_usage_timeline

Chronological executor add/remove with resource totals

get_sql_execution

SQL execution header by default; opt-in plan, node metrics, job summaries, aggregated stage metrics, and stage list

get_stage

Stage detail with attempt and task metric distributions

list_applications

List applications with optional status, date, and limit filters; pass appid for a single application's detail (status, resources, duration, attempts). Returned applications always include their attempts.

list_executors

List executors with executor-id filtering and sorting (failed-tasks/duration/gc/id)

list_jobs

List jobs with status/job-id filtering and sorting (e.g. slowest by duration)

list_sql_executions

List SQL executions as curated summaries, with status/description filters, sorting, and a default limit

list_stage_task_failures

Failed tasks of a stage with their error messages (exception/stack trace)

list_stages

List stages with status filtering and sorting (e.g. slowest by duration)