Pass Databricks Certified Data Engineer Professional Exam in First Attempt Easily
Real Databricks Certified Data Engineer Professional Exam Questions, Accurate & Verified Answers As Experienced in the Actual Test!

Verified by experts
2 products

You save $34.99

Certified Data Engineer Professional Premium Bundle

  • Premium File 339 Questions & Answers
  • Last Update: Oct 28, 2026
  • Training Course 33 Lectures
$74.99 $109.98

Purchase Individually

  • Premium File

    339 Questions & Answers
    Last Update: Oct 28, 2026

    $76.99
    $69.99
  • Training Course

    33 Lectures

    $43.99
    $39.99

Certified Data Engineer Professional Practice Test 12

Question 110

An analyst cannot tell whether an executive KPI originates from a corrected silver table or raw events.

Which catalog-governance action best improves this data product?

  1. Use Unity Catalog data lineage to trace columns and tables through supported transformations
  2. Document and centrally govern the metric definition with suitable Unity Catalog metadata or metric views
  3. Apply governed classification tags and inspect matching Unity Catalog metadata
  4. Publish accurate Unity Catalog table and column comments plus ownership metadata for governed datasets

Explanation

Correct Answer

A:

Lineage exposes input and output dependencies that cannot be reliably inferred from similarly named tables. For this situation, use Unity Catalog data lineage to trace columns and tables through supported transformations. The relevant result would be that the KPI's lineage graph identifies the expected silver source and the producing job or query.

Incorrect Answers

B:

Shared metadata and governed semantic definitions reduce ambiguous KPI interpretation across consumers. That option implements document and centrally govern the metric definition with suitable Unity Catalog metadata or metric views. It addresses a different problem; here the distinguishing need is to use Unity Catalog data lineage to trace columns and tables through supported transformations.

C:

Governed tags make classification searchable and reusable for data-discovery and policy automation. That option implements apply governed classification tags and inspect matching Unity Catalog metadata. It addresses a different problem; here the distinguishing need is to use Unity Catalog data lineage to trace columns and tables through supported transformations.

D:

Documented metadata and stewardship improve discoverability and prevent accidental use of the wrong asset. That option implements publish accurate Unity Catalog table and column comments plus ownership metadata for governed datasets. It addresses a different problem; here the distinguishing need is to use Unity Catalog data lineage to trace columns and tables through supported transformations.

Question 111

A nonprofit's overnight data pipeline keeps a large all-purpose cluster idle most of the day.

Which measurement would best prove the adjustment succeeded?

  1. The workload meets its completion SLA while idle cluster time and cost decrease
  2. Spark UI shows reduced spill and the transformation completes reliably within its agreed runtime
  3. Post-change profiles show the targeted bottleneck improved and the task meets the latency objective
  4. An injected failure causes at most one accepted charge for a business transaction identifier

Explanation

Correct Answer

A:

This directly verifies the intended outcome: the workload meets its completion SLA while idle cluster time and cost decrease. Ephemeral job compute avoids charging for long idle interactive sessions when runs are infrequent. Merely seeing a green job status does not establish that the stated business condition holds.

Incorrect Answers

B:

This would test a different behavior, chiefly profile memory pressure and select a better memory/worker configuration alongside join optimization. Compute sizing should follow measured spill and shuffle behavior rather than blind worker-count increases. The specific evidence needed here is that the workload meets its completion SLA while idle cluster time and cost decrease.

C:

This would test a different behavior, chiefly use workload profiling to identify the bottleneck before adjusting compute size or execution mode. Compute and configuration choices should match whether runtime is dominated by CPU, memory, I/O or skew. The specific evidence needed here is that the workload meets its completion SLA while idle cluster time and cost decrease.

D:

This would test a different behavior, chiefly design idempotency protection for external side effects and explicitly configure safe retry behavior. Spark and job retries can repeat side effects unless external calls are deduplicated or retries are constrained. The specific evidence needed here is that the workload meets its completion SLA while idle cluster time and cost decrease.

Question 112

The finance department asks which scheduled data jobs produced most compute spend last week.

Which observability source best answers the operator’s question?

  1. Compare SQL warehouse activity and billing usage using supported monitoring system tables
  2. Join relevant audit events by object, principal and event time in supported system tables
  3. Analyze the supported audit system tables over the relevant principal, object and time range
  4. Query the supported Databricks billing and usage system tables with workload or resource attribution

Explanation

Correct Answer

D:

System tables expose account-level metering and usage records that can be aggregated by job or compute. For this situation, query the supported Databricks billing and usage system tables with workload or resource attribution. The relevant result would be that a report reconciles workload cost totals to billing usage for the specified period and workspace.

Incorrect Answers

A:

Correlating usage and activity distinguishes busy compute from idle provisioning and waste. That option implements compare SQL warehouse activity and billing usage using supported monitoring system tables. It addresses a different problem; here the distinguishing need is to query the supported Databricks billing and usage system tables with workload or resource attribution.

B:

A timeline connecting policy changes and access requests can establish sequence better than independent screenshots. That option implements join relevant audit events by object, principal and event time in supported system tables. It addresses a different problem; here the distinguishing need is to query the supported Databricks billing and usage system tables with workload or resource attribution.

C:

Centralized audit event records provide historical evidence of actions that a current permission listing cannot show. That option implements analyze the supported audit system tables over the relevant principal, object and time range. It addresses a different problem; here the distinguishing need is to query the supported Databricks billing and usage system tables with workload or resource attribution.

Question 113

A streaming file loader is restarted following a maintenance window and must not load all earlier files twice.

Which cloud-file ingestion configuration best satisfies this requirement?

  1. Configure Auto Loader with an appropriate cloud-file source and durable schema/checkpoint location
  2. Retain rescued or quarantined source records with ingestion provenance for targeted remediation
  3. Configure the Auto Loader schema evolution strategy appropriate to the source and production contract
  4. Preserve the intended Auto Loader checkpoint and schema state across permitted restarts

Explanation

Correct Answer

D:

The checkpoint determines previously discovered input files and prevents unnecessary reprocessing on recovery. For this situation, preserve the intended Auto Loader checkpoint and schema state across permitted restarts. The relevant result would be that after restarting, the source file count remains stable and only post-restart arrivals appear as new rows.

Incorrect Answers

A:

Auto Loader tracks discovered files and incrementally processes newly arrived objects without costly full-directory enumeration. That option implements configure Auto Loader with an appropriate cloud-file source and durable schema/checkpoint location. It addresses a different problem; here the distinguishing need is to preserve the intended Auto Loader checkpoint and schema state across permitted restarts.

B:

A rescued data column or quarantine path preserves unreadable fields instead of silently dropping evidence. That option implements retain rescued or quarantined source records with ingestion provenance for targeted remediation. It addresses a different problem; here the distinguishing need is to preserve the intended Auto Loader checkpoint and schema state across permitted restarts.

C:

Schema evolution must handle newly observed fields without silently corrupting established column types. That option implements configure the Auto Loader schema evolution strategy appropriate to the source and production contract. It addresses a different problem; here the distinguishing need is to preserve the intended Auto Loader checkpoint and schema state across permitted restarts.

Question 114

A platform job receives a collection of partitions and must fan out an identical task with each partition name.

Which run-history result proves the required orchestration behavior?

  1. The run creates one iteration per region and no expected region is skipped or processed twice
  2. Job run details show the expected date passed to each dependent task and used in the output partition
  3. Task run history shows downstream publication starts only after all required upstream tasks succeed
  4. Full-reload and incremental test runs each execute only the intended branch and report the selected condition

Explanation

Correct Answer

A:

This directly verifies the intended outcome: the run creates one iteration per region and no expected region is skipped or processed twice. For Each tasks express parameterized fan-out and bound parallel work more safely than copied notebook tasks. Merely seeing a green job status does not establish that the stated business condition holds.

Incorrect Answers

B:

This would test a different behavior, chiefly declare job-level parameters and reference them in task parameters or supported task values. Explicit parameter plumbing avoids hidden notebook state and makes executions repeatable. The specific evidence needed here is that the run creates one iteration per region and no expected region is skipped or processed twice.

C:

This would test a different behavior, chiefly create a Lakeflow Job dependency graph with upstream tasks and a downstream publish task. Job task dependencies express ordering and parallelism without timing-based notebook sleeps. The specific evidence needed here is that the run creates one iteration per region and no expected region is skipped or processed twice.

D:

This would test a different behavior, chiefly use a Lakeflow Jobs If/Else condition task driven by an explicit job parameter. Conditional orchestration selects a supported branch without duplicating the entire job definition. The specific evidence needed here is that the run creates one iteration per region and no expected region is skipped or processed twice.

Question 115

A change feed can deliver the same operation twice after a network retry.

Which CDC implementation best preserves the required semantics?

  1. Use AUTO CDC with stable keys, sequence ordering, and delete handling for SCD Type 1
  2. Use AUTO CDC FROM SNAPSHOT with deterministic snapshot ordering for the supported pipeline pattern
  3. Use stable keys, sequence ordering and managed incremental pipeline state when applying AUTO CDC
  4. Use AUTO CDC configured for SCD Type 2 with the appropriate sequence column

Explanation

Correct Answer

C:

CDC target correctness relies on deterministic sequencing and replay-safe incremental state management. For this situation, use stable keys, sequence ordering and managed incremental pipeline state when applying AUTO CDC. The relevant result would be that replaying the same operation leaves one correct target version rather than multiplying changes.

Incorrect Answers

A:

AUTO CDC applies CDC events to target keys while sequencing resolves update order and delete semantics. That option implements use AUTO CDC with stable keys, sequence ordering, and delete handling for SCD Type 1. It addresses a different problem; here the distinguishing need is to use stable keys, sequence ordering and managed incremental pipeline state when applying AUTO CDC.

B:

Snapshot-oriented AUTO CDC compares successive complete versions to derive changes without a transaction log. That option implements use AUTO CDC FROM SNAPSHOT with deterministic snapshot ordering for the supported pipeline pattern. It addresses a different problem; here the distinguishing need is to use stable keys, sequence ordering and managed incremental pipeline state when applying AUTO CDC.

D:

SCD Type 2 preserves prior versions with validity periods while maintaining the current version. That option implements use AUTO CDC configured for SCD Type 2 with the appropriate sequence column. It addresses a different problem; here the distinguishing need is to use stable keys, sequence ordering and managed incremental pipeline state when applying AUTO CDC.

Question 116

A fraud pipeline performs per-row string normalization using a scalar Python UDF in a large Spark DataFrame.

Which test outcome best establishes correctness?

  1. The test fails on the intentionally changed type and passes on the approved reference schema
  2. The query plan uses native expressions and representative data produces the same normalized values with lower overhead
  3. Batch tests verify schema and values while Spark execution shows a vectorized Python processing path
  4. A test deliberately injecting duplicate rows fails while the reference transformation passes

Explanation

Correct Answer

B:

This directly verifies the intended outcome: the query plan uses native expressions and representative data produces the same normalized values with lower overhead. Native expressions benefit from Spark optimization and avoid expensive Python boundary serialization for simple operations. Merely seeing a green job status does not establish that the stated business condition holds.

Incorrect Answers

A:

This would test a different behavior, chiefly use assertSchemaEqual or equivalent schema assertions for transformation output. A schema-specific test detects incompatible types and field structure that row-count checks cannot detect. The specific evidence needed here is that the query plan uses native expressions and representative data produces the same normalized values with lower overhead.

C:

This would test a different behavior, chiefly use a supported Pandas UDF to process batches while explicitly specifying its return schema. Pandas UDFs use vectorized transfer and require the declared schema to match the returned values. The specific evidence needed here is that the query plan uses native expressions and representative data produces the same normalized values with lower overhead.

D:

This would test a different behavior, chiefly use assertDataFrameEqual on representative fixtures covering duplicate keys and nulls. DataFrame value equality exposes logical row-level changes that task-success status does not prove. The specific evidence needed here is that the query plan uses native expressions and representative data produces the same normalized values with lower overhead.

Question 117

A global model needs monthly snapshots of customer balances even when no transactions occur that month.

Which semantic or dimensional design best addresses the reporting need?

  1. Model periodic snapshot facts at the defined observation date rather than summing transactions as if they were balances
  2. Document the fact-table grain and choose aggregations that respect that grain
  3. Version and validate the governed metric definition with representative reconciliation tests
  4. Define governed Unity Catalog metric views or semantic metrics for shared measures and dimensions

Explanation

Correct Answer

A:

A balance is a point-in-time semi-additive measure and requires snapshot-aware aggregation. For this situation, model periodic snapshot facts at the defined observation date rather than summing transactions as if they were balances. The relevant result would be that monthly reports show the correct closing balance without adding balances across time periods.

Incorrect Answers

B:

Metrics are correct only when counting and summing at the intended business event level. That option implements document the fact-table grain and choose aggregations that respect that grain. It addresses a different problem; here the distinguishing need is to model periodic snapshot facts at the defined observation date rather than summing transactions as if they were balances.

C:

Metric governance requires controlled semantic changes and evidence that historical and new calculations are understood. That option implements version and validate the governed metric definition with representative reconciliation tests. It addresses a different problem; here the distinguishing need is to model periodic snapshot facts at the defined observation date rather than summing transactions as if they were balances.

D:

Central metric definitions let consumers reuse governed calculations instead of independently interpreting KPI formulas. That option implements define governed Unity Catalog metric views or semantic metrics for shared measures and dimensions. It addresses a different problem; here the distinguishing need is to model periodic snapshot facts at the defined observation date rather than summing transactions as if they were balances.

Question 118

An analyst wants customers with no successful orders in the last month.

Which join or set-processing design best preserves the data grain?

  1. Use a left anti join with the appropriately filtered successful-event dataset
  2. Join on validated business keys with an explicit cardinality check before aggregating
  3. Deduplicate records using a stable transaction identifier before SUM aggregations
  4. Resolve the intended dimension row per key or effective-time interval before the fact join

Explanation

Correct Answer

A:

Left anti joins return left-side entities that have no matching qualifying right-side record. For this situation, use a left anti join with the appropriately filtered successful-event dataset. The relevant result would be that a fixture containing customers with and without qualifying purchases yields only the unmatched set.

Incorrect Answers

B:

Correct join keys and expected cardinality prevent accidental many-to-many duplication. That option implements join on validated business keys with an explicit cardinality check before aggregating. It addresses a different problem; here the distinguishing need is to use a left anti join with the appropriately filtered successful-event dataset.

C:

Grouping alone sums repeated events unless duplicates are removed at the intended business grain. That option implements deduplicate records using a stable transaction identifier before SUM aggregations. It addresses a different problem; here the distinguishing need is to use a left anti join with the appropriately filtered successful-event dataset.

D:

Historical dimension versions require point-in-time matching to avoid multiplying facts by all versions. That option implements resolve the intended dimension row per key or effective-time interval before the fact join. It addresses a different problem; here the distinguishing need is to use a left anti join with the appropriately filtered successful-event dataset.

Question 119

A marketing aggregation spends most runtime on shuffling a small dimension into every wide partition.

Which profile evidence most directly shows the bottleneck improved?

  1. Query profile shows broadcast join execution with lower shuffle traffic and correct joined rows
  2. The long-tail task durations shrink and result totals remain equal to the baseline
  3. The tuned query uses effective file/data skipping and returns the same cohort records
  4. Spill bytes and stage tail latency decrease while aggregate values reconcile

Explanation

Correct Answer

A:

This directly verifies the intended outcome: query profile shows broadcast join execution with lower shuffle traffic and correct joined rows. Broadcasting a small relation avoids a large shuffle join when memory and size constraints allow. Merely seeing a green job status does not establish that the stated business condition holds.

Incorrect Answers

B:

This would test a different behavior, chiefly investigate key skew and apply supported skew-aware join or salting strategies where justified. Skew creates a few oversized shuffle partitions that dominate stage completion time. The specific evidence needed here is that query profile shows broadcast join execution with lower shuffle traffic and correct joined rows.

C:

This would test a different behavior, chiefly inspect query profile and file statistics to tune selective predicates and table layout. Poor filter pushdown or clustering can force unnecessary scans even when result cardinality is small. The specific evidence needed here is that query profile shows broadcast join execution with lower shuffle traffic and correct joined rows.

D:

This would test a different behavior, chiefly tune shuffle partitioning and memory strategy based on Spark UI spill and task-size evidence. Oversized shuffle partitions cause memory pressure; tuning should follow observed stage behavior. The specific evidence needed here is that query profile shows broadcast join execution with lower shuffle traffic and correct joined rows.

Question 120

A downstream warehouse must know which records are deleted when a source sends tombstone events.

Which CDC implementation best preserves the required semantics?

  1. Use AUTO CDC FROM SNAPSHOT with deterministic snapshot ordering for the supported pipeline pattern
  2. Configure AUTO CDC delete expressions for source tombstones on identified keys
  3. Use AUTO CDC configured for SCD Type 2 with the appropriate sequence column
  4. Configure a history-tracked subset or excluded-column list for AUTO CDC SCD Type 2

Explanation

Correct Answer

B:

CDC delete-handling logic translates source tombstones into target state changes instead of treating them as ordinary updates. For this situation, configure AUTO CDC delete expressions for source tombstones on identified keys. The relevant result would be that a delete event removes or closes the correct key and unrelated keys remain unchanged.

Incorrect Answers

A:

Snapshot-oriented AUTO CDC compares successive complete versions to derive changes without a transaction log. That option implements use AUTO CDC FROM SNAPSHOT with deterministic snapshot ordering for the supported pipeline pattern. It addresses a different problem; here the distinguishing need is to configure AUTO CDC delete expressions for source tombstones on identified keys.

C:

SCD Type 2 preserves prior versions with validity periods while maintaining the current version. That option implements use AUTO CDC configured for SCD Type 2 with the appropriate sequence column. It addresses a different problem; here the distinguishing need is to configure AUTO CDC delete expressions for source tombstones on identified keys.

D:

Column tracking controls which changes create new historical versions rather than versioning every technical field. That option implements configure a history-tracked subset or excluded-column list for AUTO CDC SCD Type 2. It addresses a different problem; here the distinguishing need is to configure AUTO CDC delete expressions for source tombstones on identified keys.

Certified Data Engineer Professional Practice Tests

Purchase Individually

  • Premium File

    339 Questions & Answers
    Last Update: Oct 28, 2026

    $76.99
    $69.99
  • Training Course

    33 Lectures

    $43.99
    $39.99

SPECIAL OFFER: GET 10% OFF
This is ONE TIME OFFER

You save
10%

Enter Your Email Address to Receive Your 10% Off Discount Code

SPECIAL OFFER: GET 10% OFF

You save
10%

Use Discount Code:

A confirmation link was sent to your e-mail.

Please check your mailbox for a message from support@examlabs.com and follow the directions.

Download Free Demo of VCE Exam Simulator

Experience Avanset VCE Exam Simulator for yourself.

Simply submit your email address below to get started with our interactive software demo of your free trial.

  • Realistic exam simulation and exam editor with preview functions
  • Whole exam in a single file with several different question types
  • Customizable exam-taking mode & detailed score reports