RWM Console cluster: risingwave-adib.adib-rw.svc.cluster.local

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

Job is idle — throughput ~0; structure shown.

4 operators
Sink · adib_rm.holding_breaks_sink
0% idle 2 actors
StreamScan · holding_breaks_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 · adib_rm.holding_breaks_sink Sink adib_rm.holding_breaks_… idle · 2 actors StreamScan · holding_breaks_mv StreamScan holding_breaks_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 25038 (Actor 120031,120032)
StreamSink { type: upsert, columns: [break_id, source_system, business_date, break_type, severity, status, account_id, asset_id, order_id, file_id, row_ordinal, expected, actual, detected_at, resolved_at, resolution_note, resolved_by], downstream_pk: [holding_breaks_mv.break_id] }
├── output:
│   ┌── holding_breaks_mv.break_id
│   ├── holding_breaks_mv.source_system
│   ├── holding_breaks_mv.business_date
│   ├── holding_breaks_mv.break_type
│   ├── holding_breaks_mv.severity
│   ├── holding_breaks_mv.status
│   ├── holding_breaks_mv.account_id
│   ├── holding_breaks_mv.asset_id
│   ├── holding_breaks_mv.order_id
│   ├── holding_breaks_mv.file_id
│   ├── holding_breaks_mv.row_ordinal
│   ├── holding_breaks_mv.expected
│   ├── holding_breaks_mv.actual
│   ├── holding_breaks_mv.detected_at
│   ├── holding_breaks_mv.resolved_at
│   ├── holding_breaks_mv.resolution_note
│   └── holding_breaks_mv.resolved_by
├── stream key: [ holding_breaks_mv.break_id ]
└── StreamTableScan { table: holding_breaks_mv, columns: [break_id, source_system, business_date, break_type, severity, status, account_id, asset_id, order_id, file_id, row_ordinal, expected, actual, detected_at, resolved_at, resolution_note, resolved_by] }
    ├── output:
    │   ┌── holding_breaks_mv.break_id
    │   ├── holding_breaks_mv.source_system
    │   ├── holding_breaks_mv.business_date
    │   ├── holding_breaks_mv.break_type
    │   ├── holding_breaks_mv.severity
    │   ├── holding_breaks_mv.status
    │   ├── holding_breaks_mv.account_id
    │   ├── holding_breaks_mv.asset_id
    │   ├── holding_breaks_mv.order_id
    │   ├── holding_breaks_mv.file_id
    │   ├── holding_breaks_mv.row_ordinal
    │   ├── holding_breaks_mv.expected
    │   ├── holding_breaks_mv.actual
    │   ├── holding_breaks_mv.detected_at
    │   ├── holding_breaks_mv.resolved_at
    │   ├── holding_breaks_mv.resolution_note
    │   └── holding_breaks_mv.resolved_by
    ├── stream key: [ holding_breaks_mv.break_id ]
    ├── Upstream { output: [ break_id, source_system, business_date, break_type, severity, status, account_id, asset_id, order_id, file_id, row_ordinal, expected, actual, detected_at, resolved_at, resolution_note, resolved_by ], stream key: [] }
    └── BatchPlanNode { output: [ break_id, source_system, business_date, break_type, severity, status, account_id, asset_id, order_id, file_id, row_ordinal, expected, actual, detected_at, resolved_at, resolution_note, resolved_by ], stream key: [] }