REFRESH_TABLE_PROGRESS_TRACKER

risingwave_meta::stream

Static REFRESH_TABLE_PROGRESS_TRACKER 

Source 
pub static REFRESH_TABLE_PROGRESS_TRACKER: LazyLock<Mutex<GlobalRefreshTableProgressTracker>>
Expand description

Global, per-table refresh progress tracker.

Lifecycle for each entry (keyed by TableId):

  • Created at refresh start in RefreshManager::refresh_table before any await, populated with the expected source/fetch actor sets for that table.
  • Updated on each barrier in checkpoint control when executors report list/load progress; see CheckpointControl::handle_refresh_table_info.
  • Removed when the table is reported as refresh-finished by compute on a barrier (refresh_finished_table_ids).

Failure/retry notes:

  • If scheduling the refresh fails, the table state is reset to Idle