RWM Console cluster: risingwave-ai-hub-int.ai-hub-rwm.svc.cluster.local

← cluster alpheya_agent objects tasks_sink explain
Overview Objects Graph History
sink · alpheya_agent.tasks_sink profiled over 5s
seconds (1–30)

Job is idle — throughput ~0; structure shown.

5 operators
Sink · alpheya_agent.tasks_sink
0% idle 2 actors
Project · tasks_mv
— — 2 actors
StreamScan · tasks_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Sink · alpheya_agent.tasks_sink Sink alpheya_agent.tasks_sink idle · 2 actors Project · tasks_mv Project tasks_mv — · 2 actors StreamScan · tasks_mv StreamScan tasks_mv idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand 
Fragment 19405 (Actor 157436,157435)
StreamSink { type: upsert, columns: [task_id, name, description, status, priority, due_date, assignee_id, created_by, resource_type, resource_id, updated_at], downstream_pk: [tasks_mv.task_id] }
├── output: [ tasks_mv.task_id, tasks_mv.name, tasks_mv.description, tasks_mv.status, tasks_mv.priority, tasks_mv.due_date, tasks_mv.assignee_id, tasks_mv.created_by, tasks_mv.resource_type, tasks_mv.resource_id, tasks_mv.updated_at ]
├── stream key: [ tasks_mv.task_id ]
└── StreamProject { exprs: [tasks_mv.task_id, tasks_mv.name, tasks_mv.description, tasks_mv.status, tasks_mv.priority, tasks_mv.due_date, tasks_mv.assignee_id, tasks_mv.created_by, tasks_mv.resource_type, tasks_mv.resource_id, tasks_mv.updated_at] }
    ├── output: [ tasks_mv.task_id, tasks_mv.name, tasks_mv.description, tasks_mv.status, tasks_mv.priority, tasks_mv.due_date, tasks_mv.assignee_id, tasks_mv.created_by, tasks_mv.resource_type, tasks_mv.resource_id, tasks_mv.updated_at ]
    ├── stream key: [ tasks_mv.task_id ]
    └── StreamTableScan { table: tasks_mv, columns: [task_id, name, description, due_date, status, priority, assignee_id, created_by, updated_at, resource_type, resource_id] }
        ├── output: [ tasks_mv.task_id, tasks_mv.name, tasks_mv.description, tasks_mv.due_date, tasks_mv.status, tasks_mv.priority, tasks_mv.assignee_id, tasks_mv.created_by, tasks_mv.updated_at, tasks_mv.resource_type, tasks_mv.resource_id ]
        ├── stream key: [ tasks_mv.task_id ]
        ├── Upstream { output: [ task_id, name, description, due_date, status, priority, assignee_id, created_by, updated_at, resource_type, resource_id ], stream key: [] }
        └── BatchPlanNode { output: [ task_id, name, description, due_date, status, priority, assignee_id, created_by, updated_at, resource_type, resource_id ], stream key: [] }