recovery_table_with_upstream_sinks

risingwave_meta::barrier::context::recovery

Function recovery_table_with_upstream_sinks 

Source 
fn recovery_table_with_upstream_sinks(
    inflight_jobs: &mut FragmentRenderMap,
    upstream_sink_recovery: &HashMap<JobId, UpstreamSinkRecoveryInfo>,
) -> MetaResult<()>
Expand description

For normal DDL operations, the UpstreamSinkUnion operator is modified dynamically, and does not persist the newly added or deleted upstreams in meta-store. Therefore, when restoring jobs, we need to restore the information required by the operator based on the current state of the upstream (sink) and downstream (table) of the operator. All necessary metadata must be preloaded before rendering.