hard20 pts · first answer countssparkbackfillsidempotency
Overwrite deleted the whole table
A backfill job writes one day with df.write.mode("overwrite").partitionBy("dt").parquet(path) on a path-based table. Afterwards only that day exists and all other dates are gone. Why?
Discussion 0
Join free to post in the discussion.
Related questions
- When Spark actually runsData Engineer
- What a Spark partition isData Engineer
- What causes a shuffleData Engineer
- Joining with a small lookup tableData Engineer
- Duplicates from at-least-once deliveryData Engineer
- Surprise runs from catchupData Engineer
- When to cache in SparkData Engineer
- repartition vs coalesceData Engineer