Code AnalysisIntermediate 60s
Exactly-once violated by non-idempotent sink
Pipeline pseudo-code:
for record in stream:
process(record)
sink.write(record)
checkpoint(offset)
On crash between write and checkpoint the record is reprocessed. What makes this exactly-once safe?
Think you can answer under pressure?
Get matched and answer live questions in 3-minute 1v1 battles. Elo ranking, badge tiers and bragging rights on the line.