Diagnosing skew, shuffle, and spill from Spark UI stage metrics
Spark UI stage-level metrics reveal where jobs slow down: task duration skew, shuffle read/write volume, and spill to disk all show up in the Stages tab's task summary and event timeline. Data skew appears as a small number of tasks taking far longer than the median, shuffling shows up as large shuffle read/write bytes, and spilling shows as memory spill and disk spill columns indicating a partition didn't fit in executor memory.
Must-know
- Data skew is diagnosed by comparing min/median/max task duration in the Stages tab; a max far above the median (long-tail tasks) indicates one or a few partitions hold disproportionate data.
- Shuffle read/write size and shuffle spill (memory) and shuffle spill (disk) are visible per-stage summary metrics; wide transformations (groupBy, join, distinct, repartition) trigger shuffles and are the usual root cause of skew and spill.
- Disk spilling occurs when a task's data exceeds available executor memory during a shuffle or aggregation and Spark writes intermediate data to disk, which sharply increases stage duration and I/O.
- Salting skewed join/group-by keys, using Adaptive Query Execution (AQE) to auto-optimize skewed joins and coalesce shuffle partitions, or increasing shuffle partition count are common fixes for skew and spill.
- The Spark UI SQL tab and stage DAG visualization help pinpoint which operator (join, aggregate, sort) caused the shuffle, complementing the raw stage metrics.
- A stage with many small tasks (over-partitioning) or very few large tasks (under-partitioning) both show up as inefficiency in the Stages tab and often correlate with skew or spill symptoms.
In the Spark UI, a stage shows 200 tasks total. The event timeline shows 199 tasks finish in under 10 seconds each, while 1 task runs for 12 minutes. The Summary Metrics table shows a huge gap between the 75th percentile and max for Duration and Shuffle Read Size. What does this pattern most strongly indicate?
What you have tried across Databricks DEA's objectives, not a readiness score.
Databricks Intelligence Platform
Data Ingestion and Loading
- Batch, streaming, and incremental loading patterns, and where the data comes from
- Loading files from cloud storage into governed tables with COPY INTO
- Landing data with Auto Loader, and handling schema enforcement and evolution
- Setting up Lakeflow Connect to ingest from enterprise sources reliably
- Pulling data through JDBC, ODBC, or REST clients and scheduling the job
- Choosing the right ingestion method for a given volume, frequency, and governance need
- Bringing semi-structured and unstructured data into governed Delta tables
Data Transformation and Modeling
- Cleaning bronze data into silver tables with PySpark and SQL
- Joining and combining DataFrames with the different join and union types
- Reshaping columns, rows, and arrays in a table
- Deduplicating and aggregating DataFrames
- Tuning Spark's core parameters and measuring what changed
- Building Gold-layer views and tables for BI and analytics
- Validating Silver and Gold datasets for quality
Working with Lakeflow Jobs
Implementing CI/CD
- Branching, committing, and opening pull requests from inside the Databricks workspace
- Promoting one codebase across dev, test, and prod with bundle variables and overrides
- Packaging and deploying jobs and pipelines with Automation Bundles
- Validating and managing bundle deployments from the Databricks CLI
Troubleshooting, Monitoring, and Optimization
- Spotting performance trends in a job's run history
- Reading job status, task graphs, and failure rates to monitor pipeline health
- Diagnosing skew, shuffle, and spill from Spark UI stage metrics
- What Liquid Clustering and predictive optimization actually do
- Diagnosing cluster startup failures, library conflicts, and out-of-memory errors
Governance and Security
Coverage checked against the published exam guide on Jul 26, 2026.
These are independent practice questions, written against this certification's published exam guide. They are not the certification vendor's own questions, and not the real exam.