A data engineer needs to investigate why a Lakeflow Spark Declarative Pipeline update processed far fewer records than expected. They suspect that EXPECT data quality constraints are silently dropping or quarantining records. Which tool provides data quality metrics such as expectation pass counts, fail counts, and dropped record counts for each pipeline update?
Show answer & explanation
Correct answer: A
WHY A is correct: The pipeline event log is the primary tool for extracting detailed observability data from Lakeflow Spark Declarative Pipeline updates. It records data lineage (which source datasets fed which outputs), data quality metrics (expectation name, number of records that passed vs. failed per constraint, records dropped or quarantined), and resource usage for each pipeline update. When data quality expectations are causing unexpected record counts, the event log is the correct diagnostic resource — it provides per-expectation pass/fail breakdowns that are not available in any other single location.
WHY NOT C: The cluster Metrics tab on the Compute page shows hardware metrics (CPU, memory) and Spark job-level metrics (active tasks, shuffle bytes). It does not contain dataset-level data quality metrics such as expectation pass/fail counts or record counts filtered by pipeline expectations.
WHY NOT B: system.lakeflow.job_task_run_timeline contains per-task run metadata for Databricks Jobs (start time, end time, result state). Pipelines are not structured as multi-task jobs in the same way, and this table does not contain data quality metrics such as expectation enforcement outcomes.
WHY NOT D: The Spark UI's SQL tab shows the execution plans and logical/physical plans for SQL queries, including estimated and actual row counts at the operator level. While useful for understanding query execution, it does not surface pipeline-level data quality metrics tied to specific EXPECT constraint violations or dropped record counts by expectation name.