tasks_sink · explain — RWM Console

sink · alinma_bff.tasks_sink profiled over 5s

Job is idle — throughput ~0; structure shown.

Heat tree Operator graph

4 operators

Sink · alinma_bff.tasks_sink

0% idle 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.

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

Fragments (DESCRIBE FRAGMENTS) — click to expand

Fragment 44466 (Actor 742113,742114)
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.task_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_by
│   ├── tasks_mv.created_at
│   ├── tasks_mv.updated_at
│   ├── tasks_mv.is_automated
│   ├── tasks_mv.automation_type
│   ├── tasks_mv.resource_account_id
│   ├── tasks_mv.resource_client_id
│   ├── tasks_mv.resource_portfolio_id
│   ├── tasks_mv.resource_party_id
│   ├── tasks_mv.resource_draft_account_id
│   ├── tasks_mv.resource_referral_id
│   ├── tasks_mv.resource_type
│   └── tasks_mv.resource_id
├── stream key: [ tasks_mv.task_id ]
└── StreamTableScan { table: tasks_mv, 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.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_by
    │   ├── tasks_mv.created_at
    │   ├── tasks_mv.updated_at
    │   ├── tasks_mv.is_automated
    │   ├── tasks_mv.automation_type
    │   ├── tasks_mv.resource_account_id
    │   ├── tasks_mv.resource_client_id
    │   ├── tasks_mv.resource_portfolio_id
    │   ├── tasks_mv.resource_party_id
    │   ├── tasks_mv.resource_draft_account_id
    │   ├── tasks_mv.resource_referral_id
    │   ├── 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_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-alinma.alinma-rw.svc.cluster.local