A team is running a streaming query that reads from Kafka and writes to a file sink in Parquet format. The query is failing intermittently with 'File already exists' errors. They suspect the checkpoint is not being used correctly. What is the most likely cause and solution?

The file sink is writing to a directory that already contains data; use a new directory

The checkpoint location is not set; set a unique checkpoint directory

The output mode is set to update; change it to append

The trigger interval is too short; increase it

DatabricksCertified Associate Developer for Apache Spark

Domain 5Objective 2

Create and Write Streaming DataFrames and Streaming Datasets, Including the Basic Output Modes and Output Sinks. ASSOCIATE-DEVELOPER-APACHE-SPARK Practice Questions (Page 2)

Part of the Structured Streaming domain, which accounts for 10% of the ASSOCIATE-DEVELOPER-APACHE-SPARK exam. Databricks does not publish an official question count, but from its 90-minute exam (~35–60 total, ~4–6 in this domain), expect 1–2 from this objective — we provide 13 practice questions to prepare you well beyond it. (estimate)

13questions here

3free pages

4concepts

10%of the exam

Questions 6–10

6application · medium
A team is writing a streaming query that reads from Kafka and writes to a Delta table. They need to ensure that the output is written exactly once, even if the query restarts. Which sink configuration provides this guarantee?
Select an answer first
7expert · hard
A team is running a streaming query that reads from Kafka and writes to a file sink in Parquet format. The query is failing intermittently with 'File already exists' errors. They suspect the checkpoint is not being used correctly. What is the most likely cause and solution?
Select an answer first
8application · medium
A team is building a streaming pipeline that reads from Kafka and writes to a Delta table. They need to ensure that the query can be restarted without reprocessing old data. What is the minimum configuration required?
Select an answer first
9foundation · easy
Which method is used to start a streaming query after configuring the sink and output mode?
Select an answer first
10foundation · easy
Which sink is best suited for applying arbitrary DataFrame operations to each micro-batch of a streaming query?
Select an answer first

Finished these 5 questions?

Review the revealed explanations, or continue through the curriculum.

Next 5 questions →Back to ASSOCIATE-DEVELOPER-APACHE-SPARK

Free Basic Practice is a study aid with revealable answers — not a scored exam. Examers.io is independent and not affiliated with or endorsed by Databricks. “ASSOCIATE-DEVELOPER-APACHE-SPARK” is a trademark of its owner, used for identification only.

Create and Write Streaming DataFrames and Streaming Datasets, Including the Basic Output Modes and Output Sinks. ASSOCIATE-DEVELOPER-APACHE-SPARK Practice Questions (Page 2)

Questions 6–10

A team is writing a streaming query that reads from Kafka and writes to a Delta table. They need to ensure that the output is written exactly once, even if the query restarts. Which sink configuration provides this guarantee?

A team is running a streaming query that reads from Kafka and writes to a file sink in Parquet format. The query is failing intermittently with 'File already exists' errors. They suspect the checkpoint is not being used correctly. What is the most likely cause and solution?

A team is building a streaming pipeline that reads from Kafka and writes to a Delta table. They need to ensure that the query can be restarted without reprocessing old data. What is the minimum configuration required?

Which method is used to start a streaming query after configuring the sink and output mode?

Which sink is best suited for applying arbitrary DataFrame operations to each micro-batch of a streaming query?

Keep studying — Structured Streaming