Apache Spark History MCP Server

Connect AI agents and engineers to Apache Spark History Server for intelligent job analysis, performance monitoring, and investigation

Local server

What is the Apache Spark History MCP Server?

Apache Spark History is an MCP project maintained in the kubeflow/mcp-apache-spark-history-server repository. The maintainer describes its purpose as “Connect AI agents and engineers to Apache Spark History Server for intelligent job analysis, performance monitoring, and investigation”. Read the project documentation for the complete scope.

Source

Project documentation · Repository · Discovery listing. This profile records the public documentation checked on 2026-10-08.

Recorded tools

Check the linked publisher documentation and your connected client's tool list. Names and availability can vary with the server version and account permissions.

ToolWhat it does
list_applicationsList applications with optional status, date, and limit filters; pass app_id for a single application's detail (status, resources, duration, attempts).…
list_jobsList jobs with status/job-id filtering and sorting (e.g. slowest by duration)
list_stagesList stages with status filtering and sorting (e.g. slowest by duration)
get_stageStage detail with attempt and task metric distributions
list_stage_task_failuresFailed tasks of a stage with their error messages (exception/stack trace)
list_executorsList executors with executor-id filtering and sorting (failed-tasks/duration/gc/id)
get_executor_summaryAggregate metrics across all executors
get_resource_usage_timelineChronological executor add/remove with resource totals
get_executor_thread_dumpJVM thread dump for a driver/executor, with state/name/blocked filters (running apps only)
get_environmentSpark config, JVM info, system properties, classpath; optional section filter to return a single part
list_sql_executionsList SQL executions as curated summaries, with status/description filters, sorting, and a default limit
get_sql_executionSQL execution header by default; opt-in plan, node metrics, job summaries, aggregated stage metrics, and stage list
compare_sql_executionsCompare aggregated performance metrics (stages, tasks, shuffle, spill, GC) between two SQL executions; opt-in plan-structure diff
get_job_bottlenecksIdentify bottlenecks across stages, tasks, and executors
compare_job_environmentsDiff Spark configs between two applications
compare_job_performanceDiff performance metrics between two applications
compare_stagesCompare two stages (optionally across applications): stage metrics and per-task p25/p50/p75/max quantiles
aws_analyze_spark_workloadOne-shot root cause analysis of failed/slow Spark workloads
aws_spark_code_recommendationCode fix recommendations for identified Spark issues