Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
03-30-2023 03:49 AM
Can you try to also set the maxFilespertrigger in the sink?
spark.readStream.format("delta")
.option("maxFilesPerTrigger", "100")
.load(silver_path)
.writeStream
.option("checkpointLocation", gold_checkpoint_path)
.option("maxFilesPerTrigger", "100")
.trigger(once=True)
.foreachBatch(foreachBatchFunction)
.start()