Skip to main content

aggregate_v3_sink_errors

risingwave_meta::barrier::context::context_impl

Function aggregate_v3_sink_errors 

Source 
fn aggregate_v3_sink_errors(
    phase: &'static str,
    errs: Vec<(SinkId, Error)>,
) -> Error
Expand description

Combine per-sink errors from a fan-out into a single anyhow::Error. The first failing sink’s error is used as the source so the original chain is preserved; the message lists every failing sink_id and its error stringified.