p00318821-eng/skills-plugins-hooks-agents/spark-operations-cli

Claude Code and agent skill by p00318821-eng/skills-plugins-hooks-agents

Trust tier 2
  • community
Source check pending

Checking that the SKILL.md file is still in the repository.

Diagnose failed Spark jobs, unhealthy Livy sessions, and performance bottlenecks in Microsoft Fabric via read-only CLI triage. Use when the user wants to: (1) diagnose why a Spark job, notebook run, or Lakehouse job failed, (2) triage stuck or dead Livy sessions, (3) identify OOM, shuffle spill, or data skew, (4) retrieve driver and executor logs or Spark Advisor findings, (5) copy event logs and start a local Spark History Server, (6) diagnose all Spark activities within a failed pipeline run. Triggers: "diagnose my failed notebook", "why did my spark job fail", "triage spark failure", "diagnose pipeline run failure", "why did my pipeline fail", "livy session stuck in starting", "spark executor OOM", "check spark advisor findings", "shuffle spill diagnosis", "why did my lakehouse job fail", "diagnose lakehouse table load", "data skew diagnosis", "open spark history server locally", "analyze spark failure logs", "spark job triage".

Install

npx vskill@latest install p00318821-eng/skills-plugins-hooks-agents/spark-operations-cli

SKILL.md

Update Check — ONCE PER SESSION (mandatory)
The first time this skill is used in a session, run the check-updates skill before proceeding.
- GitHub Copilot CLI / VS Code: invoke the check-updates skill.
- Claude Code / Cowork / Cursor / Windsurf / Codex: compare local vs remote package.json version.
- Skip if the check was already performed earlier in this session.
CRITICAL NOTES
1. To find the workspace details (including its ID) from workspace name: list all workspaces and, then, use JMESPath filtering
2. To find the item details (including its ID) from workspace ID, item type, and item name: list all items of that type in that workspace and, then, use JMESPath filtering
3. Skill disambiguation: spark-operations-cli is for read-only triage and diagnosis of existing jobs and sessions. For creating notebooks, running new jobs, or Spark development, use spark-authoring-cli. For interactive PySpark analysis and Livy session creation, use spark-consumption-cli.

Spark Operations — CLI Skill

This skill provides diagnostics for Microsoft Fabric Spark job failures, Livy session health, and performance bottlenecks using Fabric REST APIs and CLI tools (az rest). All diagnostic operations are read-only; session cleanup (e.g., stopping zombie sessions) requires explicit user confirmation. For Spark development and notebook authoring, use spark-authoring-cli. For interactive PySpark analysis, use spark-consumption-cli.

Table of Contents

The TOC is grouped by purpose. Start at Diagnostic Workflows when triaging an active failure; the earlier sections are foundational references.

1. Fabric Foundations (concepts)
TaskReferenceNotes
Fabric Topology & Key ConceptsCOMMON-CORE.md § Fabric Topology & Key Concepts
Environment URLsCOMMON-CORE.md § Environment URLs
Authentication & Token AcquisitionCOMMON-CORE.md § Authentication & Token AcquisitionWrong audience = 401; read before any auth issue
Core Control-Plane REST APIsCOMMON-CORE.md § Core Control-Plane REST APIs
PaginationCOMMON-CORE.md § Pagination
Long-Running Operations (LRO)COMMON-CORE.md § Long-Running Operations (LRO)
Rate Limiting & ThrottlingCOMMON-CORE.md § Rate Limiting & Throttling
Job ExecutionCOMMON-CORE.md § Job Execution
Capacity ManagementCOMMON-CORE.md § Capacity Management
Gotchas & TroubleshootingCOMMON-CORE.md § Gotchas & Troubleshooting
Best PracticesCOMMON-CORE.md § Best Practices
2. CLI Setup & Authentication
TaskReferenceNotes
Tool Selection RationaleCOMMON-CLI.md § Tool Selection Rationale
Finding Workspaces and Items in FabricCOMMON-CLI.md § Finding Workspaces and Items in FabricMandatory — READ link first [needed for finding workspace id by its name or item id by its name, item type, and workspace id]
Authentication RecipesCOMMON-CLI.md § Authentication Recipesaz login flows and token acquisition
Fabric Control-Plane API via az restCOMMON-CLI.md § Fabric Control-Plane API via az restAlways pass `--resource https://api.fabric.microsoft.com` or az rest fails
Pagination PatternCOMMON-CLI.md § Pagination Pattern
Long-Running Operations (LRO) PatternCOMMON-CLI.md § Long-Running Operations (LRO) Pattern
Gotchas & Troubleshooting (CLI-Specific)COMMON-CLI.md § Gotchas & Troubleshooting (CLI-Specific)az rest audience, shell escaping, token expiry
Quick Reference: az rest TemplateCOMMON-CLI.md § Quick Reference: az rest Template
Quick Reference: Token Audience / CLI Tool MatrixCOMMON-CLI.md § Quick Reference: Token Audience ↔ CLI Tool MatrixWhich --resource + tool for each service
3. Spark Sessions, Notebooks & Jobs (background)
TaskReferenceNotes
Livy Session ManagementSPARK-CONSUMPTION-CORE.md § Livy Session ManagementSession creation, states, lifecycle, termination
Interactive Data ExplorationSPARK-CONSUMPTION-CORE.md § Interactive Data ExplorationStatement execution, output retrieval, data discovery
Notebook Execution & Job ManagementSPARK-AUTHORING-CORE.md § Notebook Execution & Job Management
4. Spark Monitoring APIs (primary triage surface)
TaskReferenceNotes
Spark Monitoring API OverviewSPARK-MONITORING-CORE.md § OverviewGA monitoring APIs — no active session required
Workspace & Item Session ListingSPARK-MONITORING-CORE.md § Workspace and Item-Level Session ListingList Spark apps across workspace with filtering
Spark Advisor APISPARK-MONITORING-CORE.md § Spark Advisor APIKey — automated skew detection, task errors, recommendations
Open-Source Spark History Server APIsSPARK-MONITORING-CORE.md § Open-Source Spark History Server APIsJobs, stages, executors, SQL queries via REST
Driver and Executor Log APIsSPARK-MONITORING-CORE.md § Driver and Executor Log APIsDirect log retrieval without active session
Livy Log APISPARK-MONITORING-CORE.md § Livy Log APISession-level log with byte-offset pagination
Resource Usage APISPARK-MONITORING-CORE.md § Resource Usage APIvCore timeline, idle/running cores, efficiency metrics
Monitoring Diagnostic WorkflowSPARK-MONITORING-CORE.md § Diagnostic Workflow Using Monitoring APIsStep-by-step triage using monitoring APIs
5. Diagnostic Workflows (start here for active triage)
TaskReferenceNotes
Automated Diagnostic Workflow (full)automated-diagnostic-workflow.mdSteps 1–7: resolve → route by state → failure/perf/resource/health → report. Includes Step 1b expired-data fallback and report templates
Diagnostic Tiersdiagnostic-workflow.md § Diagnostic TiersTier 1 (online REST) vs Tier 2 (local SHS)
Key Diagnostic Patternsdiagnostic-workflow.md § Key Diagnostic PatternsSymptom → first check → likely cause lookup
Severity Thresholdsdiagnostic-workflow.md § Severity ThresholdsMetric thresholds for classifying findings
Manual CLI Recipesdiagnostic-workflow.md § Manual CLI RecipesAd-hoc diagnostic commands for manual use
Pipeline Run Diagnosispipeline-diagnosis.mdDiagnose all Spark activities within a pipeline run (Steps P1–P6)
6. Job Failure Diagnostics
TaskReferenceNotes
Failure Triage Workflowjob-diagnostics.md § Failure Triage WorkflowStep-by-step decision tree for diagnosing failures
Job Failure Classificationjob-diagnostics.md § Failure ClassificationOOM, shuffle, timeout, dependency, configuration errors
Reading Spark Logs via RESTjob-diagnostics.md § Reading Spark Logs via RESTDriver/executor log retrieval from Livy
Job Instance Historyjob-diagnostics.md § Job Instance HistoryQuery recent runs, compare durations, detect regressions
7. Livy Session Health
TaskReferenceNotes
Session Health Assessmentsession-health.md § Livy Session LifecycleSession states, transitions, expected durations
Idle and Zombie Session Detectionsession-health.md § Idle and Zombie Session DetectionFind and clean up leaked sessions
Session Resource Monitoringsession-health.md § Session Resource MonitoringMemory and executor usage via Livy
Session Recovery Patternssession-health.md § Session Recovery PatternsRestart strategies and session replacement
8. Performance Diagnostics
TaskReferenceNotes
Performance Anti-Patternsperformance-patterns.md § Anti-PatternsSpill, shuffle, skew, small files, collect misuse
Stage and Task Analysisperformance-patterns.md § Stage and Task AnalysisReading Spark UI metrics via REST
Optimization Recipesperformance-patterns.md § Optimization RecipesPartition tuning, broadcast joins, caching
Capacity and Resource Diagnosticsperformance-patterns.md § Capacity and Resource DiagnosticsCU consumption, throttling detection
9. Offline / Deep-Dive Tools
TaskReferenceNotes
JobInsight Event Log Copyjobinsight-api.md § LogUtils.copyEventLogCopy event logs from Fabric to OneLake for offline analysis
Local Spark History Serverspark-history-server.md § OverviewStart local SHS for full Spark UI (DAG, tasks, SQL plans)

Must/Prefer/Avoid

MUST DO

This is the start of the file. Read the full SKILL.md on GitHub.

Security

  • Security scanPassed, 100 of 100Pattern checks on the skill's files.
  • Model reviewPassed

Quality evaluation

  • Task evaluationNot runNo evaluation yet. Run one in Skill Studio.

Source

Popularity

7-day trend score
5

Not refreshed yet.

Works with

Any agent vskill installs to: 56 targets in all. These 39 have a page on this site.

  • Claude Code
  • Cursor
  • GitHub Copilot
  • Windsurf
  • Codex
  • Gemini CLI
  • Cline
  • Amp
  • Roo Code
  • Goose
  • Continue
  • Kilo Code
  • Junie
  • Trae
  • OpenHands
  • Qwen Code
  • AI Agent
  • Tabnine Chat
  • Sourcegraph Cody
  • Amazon Q
  • Firebase Genkit
  • Sweep
  • Devin
  • Phind
  • Mentat
  • Claude Desktop
  • Aider
  • GPT Pilot
  • Plandex
  • bolt.new
  • v0
  • Replit Agent
  • Anse
  • TypingMind
  • BetterChatGPT
  • LibreChat
  • Warp AI
  • Pieces
  • Fig AI
Embed badge
vskill VERIFIED badge
[![vskill VERIFIED](https://verified-skill.com/api/v1/skills/p00318821-eng/skills-plugins-hooks-agents/spark-operations-cli/badge)](https://verified-skill.com/skills/p00318821-eng/skills-plugins-hooks-agents/spark-operations-cli)

Something wrong with this skill or its page? Tell us.