cancel
Showing results forย 
Search instead forย 
Did you mean:ย 
Data Engineering
Join discussions on data engineering best practices, architectures, and optimization strategies within the Databricks Community. Exchange insights and solutions with fellow data engineers.
cancel
Showing results forย 
Search instead forย 
Did you mean:ย 

Delta live table blocks pipeline autoloader rate limit

Rdipak
New Contributor II

I have created a ETL pipeline with DLT. My first step is to ingest into raw delta table using autoloader file notification. 
when I have 20k notification pipe line run well across all stages. But when we have surge in number of messages pipeline waits for first step to complete before processing next steps. 
this is strange considering my first step is a streaming delta table and next steps has dependency on this. 
question: is it possible to use rate limit with autoloader file notification implementation? 

2 REPLIES 2

kulkpd
Contributor

Did you try following options:

.option('cloudFiles.maxFilesPerTrigger', 10000) or maxBytesPerTrigger ?

Rdipak
New Contributor II

yep set it to 15K. Does these impact when running using file notification?

I am looking at parallel fetch whats the upper limit for this?

How to derive this number, is it based on number of workers, executors or cores?

Connect with Databricks Users in Your Area

Join a Regional User Group to connect with local Databricks users. Events will be happening in your city, and you wonโ€™t want to miss the chance to attend and share knowledge.

If there isnโ€™t a group near you, start one and help create a community that brings people together.

Request a New Group