Free Access Databricks.Databricks-Certified-Professional-Data-Engineer.v2026-11-02.q167 Practice Test (Page 28)

Question 131

A Databricks job has been configured with 3 tasks, each of which is a Databricks notebook. Task A does not depend on other tasks. Tasks B and C run in parallel, with each having a serial dependency on task A.
If tasks A and B complete successfully but task C fails during a scheduled run, which statement describes the resulting state?

A.All logic expressed in the notebook associated with tasks A and B will have been successfully completed; some operations in task C may have completed successfully.

B.All logic expressed in the notebook associated with tasks A and B will have been successfully completed; any changes made in task C will be rolled back due to task failure.

C.All logic expressed in the notebook associated with task A will have been successfully completed; tasks B and C will not commit any changes because of stage failure.

D.Because all tasks are managed as a dependency graph, no changes will be committed to the Lakehouse until ail tasks have successfully been completed.

E.Unless all tasks complete successfully, no changes will be committed to the Lakehouse; because task C failed, all commits will be rolled back automatically.

Question 132

A table is registered with the following code:

Bothusersandordersare Delta Lake tables. Which statement describes the results of queryingrecent_orders?

A.All logic will execute at query time and return the result of joining the valid versions of the source tables at the time the query finishes.

B.All logic will execute when the table is definedand store the result of joiningtables to the DBFS; this stored data will be returned when the table is queried.

C.Results will be computed and cached when the table is defined; these cached results will incrementally update as new records are inserted into source tables.

D.All logic will execute at query time and return the result of joining the valid versions of the source tables at the time the query began.

E.The versions of each source table will be stored in the table transaction log; query results will be saved to DBFS with each query.

Question 133

An upstream system is emitting change data capture (CDC) logs that are being written to a cloud object storage directory. Each record in the log indicates the change type (insert, update, or delete) and the values for each field after the change. The source table has a primary key identified by the fieldpk_id.
For auditing purposes, the data governance team wishes to maintain a full record of all values that have ever been valid in the source system. For analytical purposes, only the most recent value for each record needs to be recorded. The Databricks job to ingest these records occurs once per hour, but each individual record may have changed multiple times over the course of an hour.
Which solution meets these requirements?

A.Create a separate history table for each pk_id resolve the current state of the table by running a union all filtering the history tables for the most recent state.

B.Use merge into to insert, update, or delete the most recent entry for each pk_id into a bronze table, then propagate all changes throughout the system.

C.Iterate through an ordered set of changes to the table, applying each in turn; rely on Delta Lake's versioning ability to create an audit log.

D.Use Delta Lake's change data feed to automatically process CDC data from an external system, propagating all changes to all dependent tables in the Lakehouse.

E.Ingest all log information into a bronze table; use merge into to insert, update, or delete the most recent entry for each pk_id into a silver table to recreate the current table state.

Question 134

The data engineering team has configured a Databricks SQL query and alert to monitor the values in a Delta Lake table. Therecent_sensor_recordingstable contains an identifyingsensor_idalongside thetimestampandtemperaturefor the most recent 5 minutes of recordings.
The below query is used to create the alert:

The query is set to refresh each minute and always completes in less than 10 seconds. The alert is set to trigger whenmean (temperature) > 120. Notifications are triggered to be sent at most every 1 minute.
If this alert raises notifications for 3 consecutive minutes and then stops, which statement must be true?

A.The total average temperature across all sensors exceeded 120 on three consecutive executions of the query

B.Therecent_sensor_recordingstable was unresponsive for three consecutive runs of the query

C.The source query failed to update properly for three consecutive minutes and then restarted

D.The maximum temperature recording for at least one sensor exceeded 120 on three consecutive executions of the query

E.The average temperature recordings for at least one sensor exceeded 120 on three consecutive executions of the query

Question 135

Which of the following operations are not supported on a streaming dataset view?
spark.readStream.format("delta").table("sales").createOrReplaceTempView("streaming_view")

A.SELECT sum(unitssold) FROM streaming_view

B.SELECT max(unitssold) FROM streaming_view

C.SELECT id, sum(unitssold) FROM streaming_view GROUP BY id ORDER BY id

D.SELECT id, count(*) FROM streaming_view GROUP BY id

E.SELECT * FROM streadming_view ORDER BY id