Skip to main content

snapshot_backfill_max_pending_barrier_num

risingwave_meta::barrier::checkpoint::independent_job

Function snapshot_backfill_max_pending_barrier_num 

Source 
pub fn snapshot_backfill_max_pending_barrier_num(
    in_flight_barrier_nums: usize,
    snapshot_backfill_barrier_amplification_factor: usize,
) -> usize
Expand description

The maximum number of upstream barriers a snapshot backfill partial graph may queue before the upstream is back-pressured.