Question 680
A streaming job stops processing after its deployment. The current environment exhibits the following problem: new events arrive but the sink remains stale due to repeated output errors. Which approach best satisfies this requirement?
Explanation
Correct Answer
Inspect sink permissions and microbatch write diagnostics. Source consumption is not proof that destination writes succeeded.
Incorrect Answers
The source checkpoint path was deleted during a workspace cleanup. Streaming progress depends on durable offset state.
Two streaming queries accidentally use the same checkpoint directory. Shared state can cause inconsistent offsets or query failures.
Event-time parsing fails for source timestamps with unexpected offsets. Watermark logic requires valid event timestamps.