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

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

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
16 operators
Sink · insights.portfolios_sink
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
HashJoin · LeftOuter · portfolios_dm.service_type_id = service_types_dm.service_ty… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · service_types_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · portfolios_dm
— — 2 actors
Filter · portfolios_dm
0% idle 2 actors
StreamScan · portfolios_dm
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 · insights.portfolios_sink Sink insights.portfolios_sink idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors HashJoin · LeftOuter · portfolios_dm.service_type_id = service_types_dm.service_ty… HashJoin LeftOuter · portfolios_… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · service_types_dm StreamScan service_types_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · portfolios_dm Project portfolios_dm — · 2 actors Filter · portfolios_dm Filter portfolios_dm idle · 2 actors StreamScan · portfolios_dm StreamScan portfolios_dm 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 5356 (Actor 97039,97040)
StreamSink { type: upsert, columns: [portfolio_id, service_type, portfolios_dm.service_type_id(hidden), service_types_dm.service_type_id(hidden)], downstream_pk: [portfolios_dm.portfolio_id] }
├── output: [ portfolios_dm.portfolio_id, service_types_dm.type, portfolios_dm.service_type_id, service_types_dm.service_type_id ]
├── stream key: [ portfolios_dm.portfolio_id, portfolios_dm.service_type_id ]
└── MergeExecutor
    ├── output: [ portfolios_dm.portfolio_id, service_types_dm.type, portfolios_dm.service_type_id, service_types_dm.service_type_id ]
    └── stream key: [ portfolios_dm.portfolio_id, portfolios_dm.service_type_id ]

Fragment 5357 (Actor 97042,97041)
StreamHashJoin { type: LeftOuter, predicate: portfolios_dm.service_type_id = service_types_dm.service_type_id }
├── output: [ portfolios_dm.portfolio_id, service_types_dm.type, portfolios_dm.service_type_id, service_types_dm.service_type_id ]
├── stream key: [ portfolios_dm.portfolio_id, portfolios_dm.service_type_id ]
├── MergeExecutor { output: [ portfolios_dm.portfolio_id, portfolios_dm.service_type_id ], stream key: [ portfolios_dm.portfolio_id ] }
└── MergeExecutor { output: [ service_types_dm.service_type_id, service_types_dm.type ], stream key: [ service_types_dm.service_type_id ] }

Fragment 5358 (Actor 98389,98388)
StreamProject { exprs: [portfolios_dm.portfolio_id, portfolios_dm.service_type_id] }
├── output: [ portfolios_dm.portfolio_id, portfolios_dm.service_type_id ]
├── stream key: [ portfolios_dm.portfolio_id ]
└── StreamFilter { predicate: IsNull(portfolios_dm.disabled_at) }
    ├── output: [ portfolios_dm.portfolio_id, portfolios_dm.service_type_id, portfolios_dm.disabled_at ]
    ├── stream key: [ portfolios_dm.portfolio_id ]
    └── StreamTableScan { table: portfolios_dm, columns: [portfolio_id, service_type_id, disabled_at] }
        ├── output: [ portfolios_dm.portfolio_id, portfolios_dm.service_type_id, portfolios_dm.disabled_at ]
        ├── stream key: [ portfolios_dm.portfolio_id ]
        ├── Upstream { output: [ portfolio_id, service_type_id, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ portfolio_id, service_type_id, disabled_at ], stream key: [] }

Fragment 5359 (Actor 96815,96816)
StreamTableScan { table: service_types_dm, columns: [service_type_id, type] }
├── output: [ service_types_dm.service_type_id, service_types_dm.type ]
├── stream key: [ service_types_dm.service_type_id ]
├── Upstream { output: [ service_type_id, type ], stream key: [] }
└── BatchPlanNode { output: [ service_type_id, type ], stream key: [] }