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 76

Question 750

At Harborline Utilities, a consumer group needs sales totals but not transaction-level customer IDs. Observed issue: Granting SELECT on the raw fact table violates minimization. Before applying a fix, which investigation is most directly relevant?

  1. Inspect ownership and grant-management privileges in production
  2. Inspect consumer business need and raw table grants
  3. Inspect sensitive-column policy and current grants
  4. Inspect the approved export schema against current selected columns

Explanation

Correct Answer

B:

Inspect consumer business need and raw table grants. This checks the specific evidence behind granting SELECT on the raw fact table violates minimization. A governed aggregation view can expose only approved derived information. The investigation distinguishes the mechanism from an unrelated operational symptom.

Incorrect Answers

A:

Inspect ownership and grant-management privileges in production. This diagnose action addresses a different case (separation of duties), where all developers currently own production catalogs and can grant access. Separate deploy and governance roles reduce accidental privilege escalation. In the stated problem, granting SELECT on the raw fact table violates minimization; this choice would not establish the required secure view sharing decision.

C:

Inspect sensitive-column policy and current grants. This diagnose action addresses a different case (column masking), where a raw SELECT on an approved table exposes plaintext email. Unity Catalog column masks can transform sensitive values at read time. In the stated problem, granting SELECT on the raw fact table violates minimization; this choice would not establish the required secure view sharing decision.

D:

Inspect the approved export schema against current selected columns. This diagnose action addresses a different case (sensitive data suppression), where a broad SELECT still includes unstructured notes. Column suppression and data minimization prevent unnecessary sensitive-field release. In the stated problem, granting SELECT on the raw fact table violates minimization; this choice would not establish the required secure view sharing decision.

Question 751

At Granite Edge Labs, a managed Delta table serves workloads whose filter columns change each quarter. The known risk is: Manual clustering keys quickly become stale. After remediation, which ongoing signal best detects recurrence?

  1. Monitor optimization operations and cost savings
  2. Monitor plans that lose partition pruning
  3. Monitor automatic key decisions and maintenance operations
  4. Monitor reintroduction of incompatible maintenance commands

Explanation

Correct Answer

C:

Monitor automatic key decisions and maintenance operations. This watches the failure mode described by manual clustering keys quickly become stale. Automatic liquid clustering can select keys using query workload when platform prerequisites are met. It supplies a regression signal after remediation.

Incorrect Answers

A:

Monitor optimization operations and cost savings. This monitor action addresses a different case (predictive optimization), where operators run blanket manual OPTIMIZE jobs regardless of table use. Predictive optimization can automate supported managed-table maintenance based on workload signals. In the stated problem, manual clustering keys quickly become stale; this choice would not establish the required automatic clustering decision.

B:

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, manual clustering keys quickly become stale; this choice would not establish the required automatic clustering decision.

D:

Monitor reintroduction of incompatible maintenance commands. This monitor action addresses a different case (clustering versus zorder), where the proposed maintenance script also runs ZORDER on that clustered table. Liquid clustering is incompatible with concurrently applying ZORDER to the same table. In the stated problem, manual clustering keys quickly become stale; this choice would not establish the required automatic clustering decision.

Question 752

At Harborline Utilities, analysts report that a reporting query is suddenly slower. A change was deployed to address: No baseline is available for the warehouse query execution. Which test result provides the strongest evidence that the requirement is now met?

  1. Find the expected schema error and confirm it disappears after correction
  2. Confirm the profile scans fewer files with correct result rows
  3. Correlate a known failed run to its constituent failed task
  4. Compare the same query before and after a plan change

Explanation

Correct Answer

D:

Compare the same query before and after a plan change. This tests the expected result against no baseline is available for the warehouse query execution, not simply whether a job or object exists. Query history/system query records support comparison of execution time and workload.

Incorrect Answers

A:

Find the expected schema error and confirm it disappears after correction. This validate action addresses a different case (pipeline event log), where the Jobs status only reports a high-level failure. Lakeflow pipeline event logs include update-level errors and progress events. In the stated problem, no baseline is available for the warehouse query execution; this choice would not establish the required sql query history decision.

B:

Confirm the profile scans fewer files with correct result rows. This validate action addresses a different case (query profile scans), where operators assume the query is always CPU-bound. Query Profile identifies scan, pruning and shuffle behavior for SQL workloads. In the stated problem, no baseline is available for the warehouse query execution; this choice would not establish the required sql query history decision.

C:

Correlate a known failed run to its constituent failed task. This validate action addresses a different case (job operational history), where operators only see the most recent run in the Jobs UI. Jobs system records support historical analysis of runs and tasks. In the stated problem, no baseline is available for the warehouse query execution; this choice would not establish the required sql query history decision.

Question 753

Quality assurance at Silver Ridge Logistics checks a corrected workload where a data engineering job accesses a protected external API. The original fault was: An API token is committed in a Python notebook tracked in Git. Which verification is most decisive?

  1. Verify the job authenticates without the token appearing in code or logs
  2. Compare outputs on edge cases and measure stage time on representative data
  3. Run the same function in a unit test and in a production job
  4. Force a retry and verify no duplicated sink rows

Explanation

Correct Answer

A:

Verify the job authenticates without the token appearing in code or logs. This tests the expected result against an API token is committed in a Python notebook tracked in Git, not simply whether a job or object exists. Secret-backed configuration avoids embedding credentials in notebooks or deployment YAML.

Incorrect Answers

B:

Compare outputs on edge cases and measure stage time on representative data. This validate 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, an API token is committed in a Python notebook tracked in Git; this choice would not establish the required secure configuration decision.

C:

Run the same function in a unit test and in a production job. This validate action addresses a different case (transform composability), where business logic depends on notebook state and widgets. DataFrame.transform supports composable DataFrame-to-DataFrame functions. In the stated problem, an API token is committed in a Python notebook tracked in Git; this choice would not establish the required secure configuration decision.

D:

Force a retry and verify no duplicated sink rows. This validate action addresses a different case (job retry semantics), where the downstream write repeats non-idempotent side effects on retry. Retries re-execute task logic; application code must protect repeated effects. In the stated problem, an API token is committed in a Python notebook tracked in Git; this choice would not establish the required secure configuration decision.

Question 754

At Oak Valley Retail, a Python UDF fails on certain malformed nested payloads. Observed issue: Scattered print statements do not reveal the failing object shape. Before applying a fix, which investigation is most directly relevant?

  1. Compare production deployment variables with bundle target overrides
  2. Reproduce the failure with one representative malformed record
  3. Compare deployed job JSON with the version-controlled bundle
  4. Check ordering and duplicate keys in the source window specification

Explanation

Correct Answer

B:

Reproduce the failure with one representative malformed record. This checks the specific evidence behind scattered print statements do not reveal the failing object shape. Debugger breakpoints and targeted local repros help inspect code path and values. The investigation distinguishes the mechanism from an unrelated operational symptom.

Incorrect Answers

A:

Compare production deployment variables with bundle target overrides. This diagnose action addresses a different case (bundle target overrides), where development job arguments were deployed into the production target. Bundle targets can override environment-specific variables and resource settings. In the stated problem, scattered print statements do not reveal the failing object shape; this choice would not establish the required notebook debugger decision.

C:

Compare deployed job JSON with the version-controlled bundle. This diagnose action addresses a different case (databricks cli resource updates), where production configuration drifts from repository source definitions. Declarative deployment describes resources as reviewed version-controlled artifacts. In the stated problem, scattered print statements do not reveal the failing object shape; this choice would not establish the required notebook debugger decision.

D:

Check ordering and duplicate keys in the source window specification. This diagnose action addresses a different case (window latest record), where the pipeline picks an arbitrary record instead of the newest sequence. ROW_NUMBER ordered by a deterministic sequence within each key selects the desired latest row. In the stated problem, scattered print statements do not reveal the failing object shape; this choice would not establish the required notebook debugger decision.

Question 755

A data engineer at Vantage Security must troubleshoot this case: a stream groups clicks by event time in ten-minute windows. Evidence: Old keys remain in state indefinitely without a lateness bound. What should be inspected first to confirm the failure mechanism?

  1. Inspect Python UDF execution time and batch serialization in Spark UI
  2. Inspect external target keys and batch IDs after failed attempts
  3. Inspect event-time distribution and state-store growth
  4. Inspect target history columns and CDC sequence ordering

Explanation

Correct Answer

C:

Inspect event-time distribution and state-store growth. This checks the specific evidence behind old keys remain in state indefinitely without a lateness bound. Watermarks provide a lateness threshold for bounded stateful streaming operations. The investigation distinguishes the mechanism from an unrelated operational symptom.

Incorrect Answers

A:

Inspect Python UDF execution time and batch serialization in Spark UI. This diagnose 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, old keys remain in state indefinitely without a lateness bound; this choice would not establish the required event-time watermarking decision.

B:

Inspect external target keys and batch IDs after failed attempts. This diagnose action addresses a different case (streaming idempotent sink), where a retry of a completed batch produces duplicate sink rows. foreachBatch can execute a batch again and requires idempotent external writes for exactly-once effects. In the stated problem, old keys remain in state indefinitely without a lateness bound; this choice would not establish the required event-time watermarking decision.

D:

Inspect target history columns and CDC sequence ordering. This diagnose action addresses a different case (scd type 2 history), where overwrite-style updates destroy historical state needed for point-in-time reporting. SCD Type 2 records effective history instead of replacing the previous version. In the stated problem, old keys remain in state indefinitely without a lateness bound; this choice would not establish the required event-time watermarking decision.

Question 756

At Silver Ridge Logistics, a data engineering job accesses a protected external API. A change is required because: An API token is committed in a Python notebook tracked in Git. Which implementation action most directly corrects the configuration?

  1. Update foreachBatch to upsert by business key with batch idempotency
  2. Replace the Python UDF with Spark SQL built-in functions
  3. Compose transformations with DataFrame.transform and explicit configuration
  4. Replace the literal token with a permitted secret lookup in the job runtime

Explanation

Correct Answer

D:

Replace the literal token with a permitted secret lookup in the job runtime. This directly changes the feature or logic behind an API token is committed in a Python notebook tracked in Git. Secret-backed configuration avoids embedding credentials in notebooks or deployment YAML. It is the concrete configuration for the stated incident.

Incorrect Answers

A:

Update foreachBatch to upsert by business key with batch idempotency. This implement action addresses a different case (streaming idempotent sink), where a retry of a completed batch produces duplicate sink rows. foreachBatch can execute a batch again and requires idempotent external writes for exactly-once effects. In the stated problem, an API token is committed in a Python notebook tracked in Git; this choice would not establish the required secure configuration decision.

B:

Replace the Python UDF with Spark SQL built-in functions. This implement action addresses a different case (avoid python udf for sql), where the Python UDF creates an avoidable cross-language execution boundary. Built-in Spark SQL functions can execute in optimized expressions without Python UDF overhead. In the stated problem, an API token is committed in a Python notebook tracked in Git; this choice would not establish the required secure configuration decision.

C:

Compose transformations with DataFrame.transform and explicit configuration. This implement action addresses a different case (transform composability), where business logic depends on notebook state and widgets. DataFrame.transform supports composable DataFrame-to-DataFrame functions. In the stated problem, an API token is committed in a Python notebook tracked in Git; this choice would not establish the required secure configuration decision.

Question 757

Operations at Summit Consumer Goods owns a workload where a CDC feed contains inserts, updates and deletes for account records. The previously identified issue was: Applying events as append-only rows leaves outdated active accounts. Which metric or audit check best detects drift?

  1. Monitor out-of-order changes and CDC application errors
  2. Monitor new per-key ordering collisions
  3. Detect unmanaged changes to deployed job resources
  4. Audit access to the secret scope and changes to job identity

Explanation

Correct Answer

A:

Monitor out-of-order changes and CDC application errors. This watches the failure mode described by applying events as append-only rows leaves outdated active accounts. AUTO CDC or applicable APPLY CHANGES needs stable keys and sequence ordering for stateful upserts. It supplies a regression signal after remediation.

Incorrect Answers

B:

Monitor new per-key ordering collisions. This monitor action addresses a different case (cdc duplicate sequence), where the processing order for tied source events is nondeterministic. A deterministic sequencing contract needs a unique ordered event position. In the stated problem, applying events as append-only rows leaves outdated active accounts; this choice would not establish the required auto cdc keys decision.

C:

Detect unmanaged changes to deployed job resources. This monitor action addresses a different case (databricks cli resource updates), where production configuration drifts from repository source definitions. Declarative deployment describes resources as reviewed version-controlled artifacts. In the stated problem, applying events as append-only rows leaves outdated active accounts; this choice would not establish the required auto cdc keys decision.

D:

Audit access to the secret scope and changes to job identity. This monitor action addresses a different case (secure configuration), where an API token is committed in a Python notebook tracked in Git. Secret-backed configuration avoids embedding credentials in notebooks or deployment YAML. In the stated problem, applying events as append-only rows leaves outdated active accounts; this choice would not establish the required auto cdc keys decision.

Question 758

At Redwood Civic Services, a declarative pipeline needs near-real-time freshness. The known risk is: Scheduled updates are spaced several hours apart. After remediation, which ongoing signal best detects recurrence?

  1. Monitor recurring task skew in scheduled workloads
  2. Monitor source-to-target staleness and missed updates
  3. Monitor missed notification deliveries against failed runs
  4. Monitor offset lag and microbatch processing percentiles

Explanation

Correct Answer

B:

Monitor source-to-target staleness and missed updates. This watches the failure mode described by scheduled updates are spaced several hours apart. Pipeline update frequency determines available end-to-end freshness. It supplies a regression signal after remediation.

Incorrect Answers

A:

Monitor recurring task skew in scheduled workloads. This monitor 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, scheduled updates are spaced several hours apart; this choice would not establish the required pipeline update cadence decision.

C:

Monitor missed notification deliveries against failed runs. This monitor action addresses a different case (job email notification), where operators manually check the run page every morning. Lakeflow Jobs support status-triggered notifications for run outcomes. In the stated problem, scheduled updates are spaced several hours apart; this choice would not establish the required pipeline update cadence decision.

D:

Monitor offset lag and microbatch processing percentiles. This monitor action addresses a different case (streaming backlog), where consumer lag grows while microbatch intervals appear stable. Backlog growth reveals insufficient sustainable processing throughput. In the stated problem, scheduled updates are spaced several hours apart; this choice would not establish the required pipeline update cadence decision.

Question 759

Quality assurance at Northfield Analytics checks a corrected workload where a streaming table may accept only rows with nonnull transaction IDs. The original fault was: Invalid rows currently reach downstream aggregates. Which verification is most decisive?

  1. Inject an invalid record and confirm the update fails visibly
  2. Check valid decimal values and quarantined invalid strings
  3. Append null IDs and confirm they are excluded while valid IDs remain
  4. Count retained fact rows and confirm null-key records are represented

Explanation

Correct Answer

C:

Append null IDs and confirm they are excluded while valid IDs remain. This tests the expected result against invalid rows currently reach downstream aggregates, not simply whether a job or object exists. A Lakeflow expectation configured to drop invalid rows filters violations from target output.

Incorrect Answers

A:

Inject an invalid record and confirm the update fails visibly. This validate action addresses a different case (expectation fail action), where the pipeline continues despite critical null records. Fail-on-violation expectations stop updates rather than silently filtering rows. In the stated problem, invalid rows currently reach downstream aggregates; this choice would not establish the required expectation drop action decision.

B:

Check valid decimal values and quarantined invalid strings. This validate action addresses a different case (silver schema enforcement), where implicit type coercion risks invalid numeric values being stored. Schema validation and explicit casts make type conversion failures observable. In the stated problem, invalid rows currently reach downstream aggregates; this choice would not establish the required expectation drop action decision.

D:

Count retained fact rows and confirm null-key records are represented. This validate 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, invalid rows currently reach downstream aggregates; this choice would not establish the required expectation drop action decision.

Question 760

At Cascade Manufacturing, a monolithic notebook transformation cannot be tested separately. Observed issue: Business logic depends on notebook state and widgets. Before applying a fix, which investigation is most directly relevant?

  1. Compare notebook and cluster package versions and import origins
  2. Compare job parameter definitions to hard-coded notebook literals
  3. Compare production deployment variables with bundle target overrides
  4. Identify transformations depending on hidden notebook variables

Explanation

Correct Answer

D:

Identify transformations depending on hidden notebook variables. This checks the specific evidence behind business logic depends on notebook state and widgets. DataFrame.transform supports composable DataFrame-to-DataFrame functions. The investigation distinguishes the mechanism from an unrelated operational symptom.

Incorrect Answers

A:

Compare notebook and cluster package versions and import origins. This diagnose 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, business logic depends on notebook state and widgets; this choice would not establish the required transform composability decision.

B:

Compare job parameter definitions to hard-coded notebook literals. This diagnose action addresses a different case (job parameters), where code contains hard-coded region IDs and catalog names. Task parameters allow runtime-specific values without changing notebook source. In the stated problem, business logic depends on notebook state and widgets; this choice would not establish the required transform composability decision.

C:

Compare production deployment variables with bundle target overrides. This diagnose action addresses a different case (bundle target overrides), where development job arguments were deployed into the production target. Bundle targets can override environment-specific variables and resource settings. In the stated problem, business logic depends on notebook state and widgets; this choice would not establish the required transform composability decision.

Certified Data Engineer Professional Practice Tests