tasks_sink · explain — RWM Console

sink · alpheya_experience_bff.tasks_sink profiled over 5s

Job is idle — throughput ~0; structure shown.

Heat tree Operator graph

4 operators

Sink · alpheya_experience_bff.tasks_sink

0% idle 2 actors

StreamScan · tasks_mv_next

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.

Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.

Fragments (DESCRIBE FRAGMENTS) — click to expand

Fragment 14634 (Actor 159145,159146)
StreamSink { type: upsert, columns: [task_id, name, description, due_date, status, priority, assignee_id, created_by, updated_by, created_at, updated_at, is_automated, automation_type, resource_account_id, resource_client_id, resource_portfolio_id, resource_party_id, resource_draft_account_id, resource_referral_id, resource_type, resource_id], downstream_pk: [tasks_mv_next.task_id] }
├── output:
│   ┌── tasks_mv_next.task_id
│   ├── tasks_mv_next.name
│   ├── tasks_mv_next.description
│   ├── tasks_mv_next.due_date
│   ├── tasks_mv_next.status
│   ├── tasks_mv_next.priority
│   ├── tasks_mv_next.assignee_id
│   ├── tasks_mv_next.created_by
│   ├── tasks_mv_next.updated_by
│   ├── tasks_mv_next.created_at
│   ├── tasks_mv_next.updated_at
│   ├── tasks_mv_next.is_automated
│   ├── tasks_mv_next.automation_type
│   ├── tasks_mv_next.resource_account_id
│   ├── tasks_mv_next.resource_client_id
│   ├── tasks_mv_next.resource_portfolio_id
│   ├── tasks_mv_next.resource_party_id
│   ├── tasks_mv_next.resource_draft_account_id
│   ├── tasks_mv_next.resource_referral_id
│   ├── tasks_mv_next.resource_type
│   └── tasks_mv_next.resource_id
├── stream key: [ tasks_mv_next.task_id ]
└── StreamTableScan { table: tasks_mv_next, columns: [task_id, name, description, due_date, status, priority, assignee_id, created_by, updated_by, created_at, updated_at, is_automated, automation_type, resource_account_id, resource_client_id, resource_portfolio_id, resource_party_id, resource_draft_account_id, resource_referral_id, resource_type, resource_id] }
    ├── output:
    │   ┌── tasks_mv_next.task_id
    │   ├── tasks_mv_next.name
    │   ├── tasks_mv_next.description
    │   ├── tasks_mv_next.due_date
    │   ├── tasks_mv_next.status
    │   ├── tasks_mv_next.priority
    │   ├── tasks_mv_next.assignee_id
    │   ├── tasks_mv_next.created_by
    │   ├── tasks_mv_next.updated_by
    │   ├── tasks_mv_next.created_at
    │   ├── tasks_mv_next.updated_at
    │   ├── tasks_mv_next.is_automated
    │   ├── tasks_mv_next.automation_type
    │   ├── tasks_mv_next.resource_account_id
    │   ├── tasks_mv_next.resource_client_id
    │   ├── tasks_mv_next.resource_portfolio_id
    │   ├── tasks_mv_next.resource_party_id
    │   ├── tasks_mv_next.resource_draft_account_id
    │   ├── tasks_mv_next.resource_referral_id
    │   ├── tasks_mv_next.resource_type
    │   └── tasks_mv_next.resource_id
    ├── stream key: [ tasks_mv_next.task_id ]
    ├── Upstream { output: [ task_id, name, description, due_date, status, priority, assignee_id, created_by, updated_by, created_at, updated_at, is_automated, automation_type, resource_account_id, resource_client_id, resource_portfolio_id, resource_party_id, resource_draft_account_id, resource_referral_id, resource_type, resource_id ], stream key: [] }
    └── BatchPlanNode { output: [ task_id, name, description, due_date, status, priority, assignee_id, created_by, updated_by, created_at, updated_at, is_automated, automation_type, resource_account_id, resource_client_id, resource_portfolio_id, resource_party_id, resource_draft_account_id, resource_referral_id, resource_type, resource_id ], stream key: [] }

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