cert
cert-1
cert-2

Pass Databricks Certified Data Engineer Professional Exam in First Attempt Guaranteed!

Get 100% Latest Exam Questions, Accurate & Verified Answers to Pass the Actual Exam!
30 Days Free Updates, Instant Download!

cert-5
cert-6
Certified Data Engineer Professional Exam - Verified By Experts
Certified Data Engineer Professional Premium Bundle
$14.99

Certified Data Engineer Professional Premium Bundle

$74.99
$89.98
  • Premium File 339 Questions & Answers. Last update: Oct 30, 2026
  • Training Course 33 Video Lectures
 
$89.98
$74.99
accept 91 downloads in last 7 days
block-screenshots
Purchase Databricks Certified Data Engineer Professional Exam Training Products Individually
Databricks Certified Data Engineer Professional Premium File
Premium File 339 Q&A
$76.99$69.99
Databricks Certified Data Engineer Professional Video Training Course
Training Course 33 Lectures
$21.99 $19.99
Databricks Certified Data Engineer Professional Practice Test 56

Question 550

At Orion Capital, global feeds supply timestamps with inconsistent local time zones. Architecture constraint: Events from different regions are ordered incorrectly in a UTC dashboard. Which design best addresses this requirement?

  1. Separate valid silver rows from a restricted quarantine table
  2. Normalize event time consistently to UTC while preserving source timezone metadata if needed
  3. Rank events by business key, event time and a deterministic tie-breaker
  4. Preserve unmatched facts with a left join when business rules require them

Explanation

Correct Answer

B:

Normalize event time consistently to UTC while preserving source timezone metadata if needed. This design addresses events from different regions are ordered incorrectly in a UTC dashboard. Time-zone normalization is required before comparing timestamps from different sources. It establishes the right contract or architecture before execution changes.

Incorrect Answers

A:

Separate valid silver rows from a restricted quarantine table. This design action addresses a different case (quarantine bad records), where dropping invalid rows silently hides upstream quality failures. Quarantine preserves invalid events separately while allowing valid records through. In the stated problem, events from different regions are ordered incorrectly in a UTC dashboard; this choice would not establish the required timestamp timezone normalization decision.

C:

Rank events by business key, event time and a deterministic tie-breaker. This design action addresses a different case (latest-per-key with ties), where two events have the same event time and yield different surviving rows. A deterministic tie-breaker is required in a per-key window ranking. In the stated problem, events from different regions are ordered incorrectly in a UTC dashboard; this choice would not establish the required timestamp timezone normalization decision.

D:

Preserve unmatched facts with a left join when business rules require them. This design action addresses a different case (join with nullable keys), where rows with null external IDs disappear from an inner join. SQL null equality and join type determine whether unmatched rows survive. In the stated problem, events from different regions are ordered incorrectly in a UTC dashboard; this choice would not establish the required timestamp timezone normalization decision.

Question 551

At Vantage Security, an events table has high-cardinality device IDs and unpredictable daily volumes. The known risk is: Partitioning by device would produce many tiny partitions. After remediation, which ongoing signal best detects recurrence?

  1. Monitor query scans and available column stats
  2. Monitor MERGE scan bytes across incremental batches
  3. Monitor cluster-key usefulness as query patterns change
  4. Monitor plans that lose partition pruning

Explanation

Correct Answer

C:

Monitor cluster-key usefulness as query patterns change. This watches the failure mode described by partitioning by device would produce many tiny partitions. Liquid clustering organizes data by useful filter keys without high-cardinality partition directories. It supplies a regression signal after remediation.

Incorrect Answers

A:

Monitor query scans and available column stats. This monitor action addresses a different case (data skipping statistics), where file-level statistics are missing for the filter column. Delta data skipping uses collected column statistics to eliminate files. In the stated problem, partitioning by device would produce many tiny partitions; this choice would not establish the required liquid clustering cardinality decision.

B:

Monitor MERGE scan bytes across incremental batches. This monitor action addresses a different case (predicate-limited merge), where the merge scans unrelated historical partitions. Constraining merge matches to relevant partitions can reduce unnecessary target scanning. In the stated problem, partitioning by device would produce many tiny partitions; this choice would not establish the required liquid clustering cardinality decision.

D:

Monitor plans that lose partition pruning. This monitor action addresses a different case (partition pruning), where a query wraps business_date in a transformation and reads many partitions. Direct predicates on partition keys can enable partition pruning. In the stated problem, partitioning by device would produce many tiny partitions; this choice would not establish the required liquid clustering cardinality decision.

Question 552

Quality assurance at Redwood Civic Services checks a corrected workload where customers can belong to multiple service plans during the same period. The original fault was: Joining facts directly to the membership table multiplies totals. Which verification is most decisive?

  1. Reproduce an account merge and verify historical facts retain correct links
  2. Compare query file skipping and fact totals before and after
  3. Query facts as of past dates and verify the appropriate historical tier
  4. Validate distinct customer counts and allocated totals after bridge joins

Explanation

Correct Answer

D:

Validate distinct customer counts and allocated totals after bridge joins. This tests the expected result against joining facts directly to the membership table multiplies totals, not simply whether a job or object exists. A bridge table models many-to-many relationships at an explicit membership grain.

Incorrect Answers

A:

Reproduce an account merge and verify historical facts retain correct links. This validate action addresses a different case (surrogate dimension keys), where joining facts directly on mutable business IDs links history incorrectly. Stable surrogate keys decouple dimensional identity from changing source identifiers. In the stated problem, joining facts directly to the membership table multiplies totals; this choice would not establish the required many-to-many bridge decision.

B:

Compare query file skipping and fact totals before and after. This validate action addresses a different case (liquid clustering for fact models), where rigid daily partitions offer little pruning for customer filters. Liquid clustering enables query-aware data layout without high-cardinality partitioning. In the stated problem, joining facts directly to the membership table multiplies totals; this choice would not establish the required many-to-many bridge decision.

C:

Query facts as of past dates and verify the appropriate historical tier. This validate action addresses a different case (scd type 2 effective dates), where a single current tier overwrites history in the dimension. SCD Type 2 stores effective start/end intervals for distinct historical dimension versions. In the stated problem, joining facts directly to the membership table multiplies totals; this choice would not establish the required many-to-many bridge decision.

Question 553

At Cobalt Biotech, a federated analyst can see a foreign catalog but cannot query its tables. A change was deployed to address: Catalog discovery was mistaken for full table access. Which test result provides the strongest evidence that the requirement is now met?

  1. Confirm authorized query succeeds while excluded tables remain inaccessible
  2. Query a foreign table from Databricks and reconcile sampled source rows
  3. Verify recipient sees the selected dataset but not excluded tables
  4. Confirm the partner reads only the approved shared dataset

Explanation

Correct Answer

A:

Confirm authorized query succeeds while excluded tables remain inaccessible. This tests the expected result against catalog discovery was mistaken for full table access, not simply whether a job or object exists. Unity Catalog usage and object privileges are still required for foreign data objects.

Incorrect Answers

B:

Query a foreign table from Databricks and reconcile sampled source rows. This validate action addresses a different case (federated connection), where engineers export the full source database into cloud object storage each hour. Lakehouse Federation can query supported external sources through a catalog connection. In the stated problem, catalog discovery was mistaken for full table access; this choice would not establish the required foreign catalog permission decision.

C:

Verify recipient sees the selected dataset but not excluded tables. This validate action addresses a different case (share catalog scope), where the recipient can discover unintended datasets. A Delta Sharing share should contain only explicitly approved assets. In the stated problem, catalog discovery was mistaken for full table access; this choice would not establish the required foreign catalog permission decision.

D:

Confirm the partner reads only the approved shared dataset. This validate action addresses a different case (open protocol recipient), where the partner cannot use an internal Databricks-to-Databricks credential flow. Open Delta Sharing can support non-Databricks recipients using the sharing protocol. In the stated problem, catalog discovery was mistaken for full table access; this choice would not establish the required foreign catalog permission decision.

Question 554

A deployment owner at Cascade Manufacturing needs to implement a remedy: a company loads raw telemetry directly into customer-facing dashboards. The present failure is: Malformed source events contaminate metrics without an intermediate quality boundary. Which change should be applied?

  1. Enable liquid clustering and execute an eligible OPTIMIZE process
  2. Write raw events to bronze, quality checks to silver and analytics tables to gold
  3. Generate dimension surrogate IDs and reference them from fact rows
  4. Materialize the aggregate from quality-controlled silver facts

Explanation

Correct Answer

B:

Write raw events to bronze, quality checks to silver and analytics tables to gold. This directly changes the feature or logic behind malformed source events contaminate metrics without an intermediate quality boundary. Bronze, silver and gold layers separate raw capture, validated refinement and business presentation. It is the concrete configuration for the stated incident.

Incorrect Answers

A:

Enable liquid clustering and execute an eligible OPTIMIZE process. This implement action addresses a different case (liquid clustering for fact models), where rigid daily partitions offer little pruning for customer filters. Liquid clustering enables query-aware data layout without high-cardinality partitioning. In the stated problem, malformed source events contaminate metrics without an intermediate quality boundary; this choice would not establish the required medallion bronze silver gold decision.

C:

Generate dimension surrogate IDs and reference them from fact rows. This implement action addresses a different case (surrogate dimension keys), where joining facts directly on mutable business IDs links history incorrectly. Stable surrogate keys decouple dimensional identity from changing source identifiers. In the stated problem, malformed source events contaminate metrics without an intermediate quality boundary; this choice would not establish the required medallion bronze silver gold decision.

D:

Materialize the aggregate from quality-controlled silver facts. This implement action addresses a different case (aggregate gold model), where interactive queries scan billions of detail rows for identical totals. A summarized gold table can serve a stable reporting grain efficiently. In the stated problem, malformed source events contaminate metrics without an intermediate quality boundary; this choice would not establish the required medallion bronze silver gold decision.

Question 555

A data engineer at Riverbend Energy must troubleshoot this case: a large Delta fact receives unpredictable queries filtered by customer and region. Evidence: Rigid daily partitions offer little pruning for customer filters. What should be inspected first to confirm the failure mechanism?

  1. Inspect membership cardinalities and duplicated fact amounts
  2. Inspect dimension history and event order for each account key
  3. Inspect fact query predicates and current data-skipping statistics
  4. Inspect fact primary keys and duplicates at candidate grains

Explanation

Correct Answer

C:

Inspect fact query predicates and current data-skipping statistics. This checks the specific evidence behind rigid daily partitions offer little pruning for customer filters. Liquid clustering enables query-aware data layout without high-cardinality partitioning. The investigation distinguishes the mechanism from an unrelated operational symptom.

Incorrect Answers

A:

Inspect membership cardinalities and duplicated fact amounts. This diagnose action addresses a different case (many-to-many bridge), where joining facts directly to the membership table multiplies totals. A bridge table models many-to-many relationships at an explicit membership grain. In the stated problem, rigid daily partitions offer little pruning for customer filters; this choice would not establish the required liquid clustering for fact models decision.

B:

Inspect dimension history and event order for each account key. This diagnose action addresses a different case (scd type 2 effective dates), where a single current tier overwrites history in the dimension. SCD Type 2 stores effective start/end intervals for distinct historical dimension versions. In the stated problem, rigid daily partitions offer little pruning for customer filters; this choice would not establish the required liquid clustering for fact models decision.

D:

Inspect fact primary keys and duplicates at candidate grains. This diagnose action addresses a different case (fact table grain), where summing revenue double-counts orders with multiple items. A dimensional fact must have one clearly documented row grain. In the stated problem, rigid daily partitions offer little pruning for customer filters; this choice would not establish the required liquid clustering for fact models decision.

Question 556

Quality assurance at Arbor Medical checks a corrected workload where business users cannot distinguish certified customer metrics from experimental tables. The original fault was: Table and column metadata lack meaningful descriptions. Which verification is most decisive?

  1. Read the intended dataset and verify access is denied outside the scope
  2. Search tagged assets and confirm all known PII columns are classified
  3. Compare returned metadata to known visible catalog objects
  4. Search Catalog Explorer and verify definitions distinguish the assets

Explanation

Correct Answer

D:

Search Catalog Explorer and verify definitions distinguish the assets. This tests the expected result against table and column metadata lack meaningful descriptions, not simply whether a job or object exists. Unity Catalog comments improve discoverability of governed data assets.

Incorrect Answers

A:

Read the intended dataset and verify access is denied outside the scope. This validate action addresses a different case (external location governance), where raw cloud permissions bypass central catalog governance. External locations map cloud paths to governed Unity Catalog storage credentials. In the stated problem, table and column metadata lack meaningful descriptions; this choice would not establish the required catalog descriptions decision.

B:

Search tagged assets and confirm all known PII columns are classified. This validate action addresses a different case (governed tags), where naming conventions alone are inconsistent across teams. Governed tags can classify assets for discovery and policy workflows. In the stated problem, table and column metadata lack meaningful descriptions; this choice would not establish the required catalog descriptions decision.

C:

Compare returned metadata to known visible catalog objects. This validate action addresses a different case (information schema discovery), where it uses notebook-specific private metadata APIs that break after upgrades. INFORMATION_SCHEMA provides SQL metadata views subject to visibility permissions. In the stated problem, table and column metadata lack meaningful descriptions; this choice would not establish the required catalog descriptions decision.

Question 557

At Meadowland Software, a Kafka stream is processing more slowly than incoming messages. A change is required because: Consumer lag grows while microbatch intervals appear stable. Which implementation action most directly corrects the configuration?

  1. Publish source-to-sink lag metrics and tune the actual bottleneck
  2. Create a supported metrics query for failed expectation records
  3. Capture supported query-history metrics in a restricted view
  4. Change the relevant join or aggregation strategy based on Spark UI metrics

Explanation

Correct Answer

A:

Publish source-to-sink lag metrics and tune the actual bottleneck. This directly changes the feature or logic behind consumer lag grows while microbatch intervals appear stable. Backlog growth reveals insufficient sustainable processing throughput. It is the concrete configuration for the stated incident.

Incorrect Answers

B:

Create a supported metrics query for failed expectation records. This implement action addresses a different case (expectation monitoring), where analysts confuse successful pipeline status with zero rejected records. Quality metric events reveal input and dropped records separately from update status. In the stated problem, consumer lag grows while microbatch intervals appear stable; this choice would not establish the required streaming backlog decision.

C:

Capture supported query-history metrics in a restricted view. This implement action addresses a different case (sql query history), where no baseline is available for the warehouse query execution. Query history/system query records support comparison of execution time and workload. In the stated problem, consumer lag grows while microbatch intervals appear stable; this choice would not establish the required streaming backlog decision.

D:

Change the relevant join or aggregation strategy based on Spark UI metrics. This implement action addresses a different case (spark ui shuffle metrics), where operators only monitor cluster-wide CPU and miss skewed task durations. Spark UI stage metrics reveal shuffle, spill and task skew. In the stated problem, consumer lag grows while microbatch intervals appear stable; this choice would not establish the required streaming backlog decision.

Question 558

Operations at Fairhaven Transport owns a workload where a downstream incremental aggregate misses updates to an existing Delta table. The previously identified issue was: The consumer reads only newly appended rows and cannot see updates or deletes. Which metric or audit check best detects drift?

  1. Monitor state-store row counts, checkpoint size and spill
  2. Monitor consumer lag measured in committed Delta versions
  3. Monitor cluster-key usefulness as query patterns change
  4. Monitor plans that lose partition pruning

Explanation

Correct Answer

B:

Monitor consumer lag measured in committed Delta versions. This watches the failure mode described by the consumer reads only newly appended rows and cannot see updates or deletes. Delta Change Data Feed exposes row-level changes for supported versions when enabled. It supplies a regression signal after remediation.

Incorrect Answers

A:

Monitor state-store row counts, checkpoint size and spill. This monitor action addresses a different case (streaming state growth), where executor memory pressure grows even though input rate is stable. State retention and checkpoint state-store configuration affect memory requirements. In the stated problem, the consumer reads only newly appended rows and cannot see updates or deletes; this choice would not establish the required change data feed consumers decision.

C:

Monitor cluster-key usefulness as query patterns change. This monitor action addresses a different case (liquid clustering cardinality), where partitioning by device would produce many tiny partitions. Liquid clustering organizes data by useful filter keys without high-cardinality partition directories. In the stated problem, the consumer reads only newly appended rows and cannot see updates or deletes; this choice would not establish the required change data feed consumers decision.

D:

Monitor plans that lose partition pruning. This monitor action addresses a different case (partition pruning), where a query wraps business_date in a transformation and reads many partitions. Direct predicates on partition keys can enable partition pruning. In the stated problem, the consumer reads only newly appended rows and cannot see updates or deletes; this choice would not establish the required change data feed consumers decision.

Question 559

An architecture review at Northfield Analytics covers a workload where a Python ETL workload runs reliably in development but fails after the next cluster restart. The unresolved constraint is: A transitive dependency updated to an incompatible version. Which design is most appropriate?

  1. Choose a materialized view for refreshable precomputed analytics
  2. Use one managed and repeatable dependency source for the workload
  3. Choose compatible pinned versions using a tested dependency lock strategy
  4. Prefer native Spark expressions or a compatible vectorized Pandas UDF for the calculation

Explanation

Correct Answer

C:

Choose compatible pinned versions using a tested dependency lock strategy. This design addresses a transitive dependency updated to an incompatible version. Explicit compatible dependency versions improve reproducibility across new compute environments. It establishes the right contract or architecture before execution changes.

Incorrect Answers

A:

Choose a materialized view for refreshable precomputed analytics. This design action addresses a different case (materialized view choice), where each dashboard query recomputes the same expensive aggregation. A materialized view maintains a precomputed query result through refresh. In the stated problem, a transitive dependency updated to an incompatible version; this choice would not establish the required library version pinning decision.

B:

Use one managed and repeatable dependency source for the workload. This design action addresses a different case (library precedence), where a notebook-scoped installation overrides the expected cluster version. The runtime can resolve conflicting versions from different installation scopes. In the stated problem, a transitive dependency updated to an incompatible version; this choice would not establish the required library version pinning decision.

D:

Prefer native Spark expressions or a compatible vectorized Pandas UDF for the calculation. This design action addresses a different case (vectorized udf), where row-by-row Python invocation dominates stage runtime. Pandas UDFs process batches through Arrow rather than per-row Python calls. In the stated problem, a transitive dependency updated to an incompatible version; this choice would not establish the required library version pinning decision.

Question 560

Operations at Westhaven Services owns a workload where a governance team investigates an unexpected table access event. The previously identified issue was: Workspace notebook logs do not show the full audited account activity. Which metric or audit check best detects drift?

  1. Alert on cost spikes and untagged spend
  2. Track alert evaluations and delivery failures
  3. Alert on freshness lag rather than only job failure
  4. Alert on unusual sensitive-object access patterns

Explanation

Correct Answer

D:

Alert on unusual sensitive-object access patterns. This watches the failure mode described by workspace notebook logs do not show the full audited account activity. System audit tables provide security-relevant account events subject to access controls. It supplies a regression signal after remediation.

Incorrect Answers

A:

Alert on cost spikes and untagged spend. This monitor action addresses a different case (billing usage monitoring), where cost reports omit some job and workspace labels. Databricks system billing tables can expose usage records for cost attribution. In the stated problem, workspace notebook logs do not show the full audited account activity; this choice would not establish the required audit log review decision.

B:

Monitor alert evaluations and delivery failures. This monitor action addresses a different case (sql alert threshold), where the current dashboard has no automated alert for missing units. SQL alerts can evaluate a query result against a configured threshold. In the stated problem, workspace notebook logs do not show the full audited account activity; this choice would not establish the required audit log review decision.

C:

Alert on freshness lag rather than only job failure. This monitor action addresses a different case (end-to-end sla), where operators monitor compute uptime rather than data freshness. SLA monitoring should measure source event time to published table availability. In the stated problem, workspace notebook logs do not show the full audited account activity; this choice would not establish the required audit log review decision.

Certified Data Engineer Professional Practice Tests