Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
12-10-2024 07:12 AM
I tried following options
# with autoloader options
cloudFiles.fetchParallelism = 10
cloudFiles.queueFetchInterval = "500ms"
# setting this at the start of notebook execution
spark.conf.set("spark.databricks.cloudFiles.useAsyncFetch", "true")it seems to be stuck and not making any progress.
There is no data in ADLS queue for this stream but it was stuck there for more than 40mins then I cancelled the task.
If I disable/not set this property
spark.databricks.cloudFiles.useAsyncFetchit processes the stream but still takes a minute even though the queue is empty.