Module recovery

Module recovery 

Source

Structsยง

LoadedRecoveryContext ๐Ÿ”’
UpstreamSinkRecoveryInfo ๐Ÿ”’

Functionsยง

build_stream_actors ๐Ÿ”’
Assembles StreamActor instances from rendered fragment info and job context.
recovery_table_with_upstream_sinks ๐Ÿ”’
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.