risingwave_stream::executor::source::source_executor

Constant WAIT_BARRIER_MULTIPLE_TIMES

source
pub const WAIT_BARRIER_MULTIPLE_TIMES: u128 = 5;
Expand description

A constant to multiply when calculating the maximum time to wait for a barrier. This is due to some latencies in network and cost in meta.