Skip to main content

overcompacted_error

Function overcompacted_error 

Source
fn overcompacted_error(
    name: &str,
    as_of: &Antichain<Timestamp>,
    resume_upper: &Antichain<Timestamp>,
    remedy: &str,
) -> String
Expand description

Formats the error reported when a sink’s input has been compacted past the upper the sink last committed, so the sink can never resume. remedy tells the user how to recover, which differs by sink type.