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

← cluster insights objects accounts_sink explain
Overview Objects Graph History
sink · insights.accounts_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
20 operators
Sink · insights.accounts_sink
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · accounts_dm_next.product_type_id = product_types_dm_next.pr…
— — 2 actors
HashJoin · LeftOuter · accounts_dm_next.product_type_id = product_types_dm_next.pr… 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 · product_types_dm_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · accounts_dm_next
— — 2 actors
Filter · accounts_dm_next
0% idle 2 actors
StreamScan · accounts_dm_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.
Sink · insights.accounts_sink Sink insights.accounts_sink idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · accounts_dm_next.product_type_id = product_types_dm_next.pr… SyncLogStore LeftOuter · accounts_dm… — · 2 actors HashJoin · LeftOuter · accounts_dm_next.product_type_id = product_types_dm_next.pr… HashJoin LeftOuter · accounts_dm… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · product_types_dm_next StreamScan product_types_dm_next idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · accounts_dm_next Project accounts_dm_next — · 2 actors Filter · accounts_dm_next Filter accounts_dm_next idle · 2 actors StreamScan · accounts_dm_next StreamScan accounts_dm_next 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 37227 (Actor 742822,742823)
StreamSink { type: upsert, columns: [account_id, base_currency_code, is_restricted, product_type, accounts_dm_next.product_type_id(hidden), product_types_dm_next.product_type_id(hidden)], downstream_pk: [accounts_dm_next.account_id] }
├── output: [ accounts_dm_next.account_id, accounts_dm_next.base_currency_code, accounts_dm_next.is_restricted, product_types_dm_next.type, accounts_dm_next.product_type_id, product_types_dm_next.product_type_id ]
├── stream key: [ accounts_dm_next.product_type_id, accounts_dm_next.account_id ]
└── MergeExecutor
    ├── output: [ accounts_dm_next.account_id, accounts_dm_next.base_currency_code, accounts_dm_next.is_restricted, product_types_dm_next.type, accounts_dm_next.product_type_id, product_types_dm_next.product_type_id ]
    └── stream key: [ accounts_dm_next.product_type_id, accounts_dm_next.account_id ]

Fragment 37228 (Actor 742824,742825)
StreamSyncLogStore
├── output: [ accounts_dm_next.account_id, accounts_dm_next.base_currency_code, accounts_dm_next.is_restricted, product_types_dm_next.type, accounts_dm_next.product_type_id, product_types_dm_next.product_type_id ]
├── stream key: [ accounts_dm_next.product_type_id, accounts_dm_next.account_id ]
└── StreamHashJoin { type: LeftOuter, predicate: accounts_dm_next.product_type_id = product_types_dm_next.product_type_id }
    ├── output: [ accounts_dm_next.account_id, accounts_dm_next.base_currency_code, accounts_dm_next.is_restricted, product_types_dm_next.type, accounts_dm_next.product_type_id, product_types_dm_next.product_type_id ]
    ├── stream key: [ accounts_dm_next.product_type_id, accounts_dm_next.account_id ]
    ├── MergeExecutor
    │   ├── output: [ accounts_dm_next.account_id, accounts_dm_next.product_type_id, accounts_dm_next.base_currency_code, accounts_dm_next.is_restricted ]
    │   └── stream key: [ accounts_dm_next.product_type_id, accounts_dm_next.account_id ]
    └── MergeExecutor { output: [ product_types_dm_next.product_type_id, product_types_dm_next.type ], stream key: [ product_types_dm_next.product_type_id ] }

Fragment 37229 (Actor 742853,742852)
StreamLocalityProvider { locality_columns: [accounts_dm_next.product_type_id] }
├── output: [ accounts_dm_next.account_id, accounts_dm_next.product_type_id, accounts_dm_next.base_currency_code, accounts_dm_next.is_restricted ]
├── stream key: [ accounts_dm_next.product_type_id, accounts_dm_next.account_id ]
└── MergeExecutor { output: [ accounts_dm_next.account_id, accounts_dm_next.product_type_id, accounts_dm_next.base_currency_code, accounts_dm_next.is_restricted ], stream key: [ accounts_dm_next.account_id ] }

Fragment 37230 (Actor 742735,742736)
StreamProject { exprs: [accounts_dm_next.account_id, accounts_dm_next.product_type_id, accounts_dm_next.base_currency_code, accounts_dm_next.is_restricted] }
├── output: [ accounts_dm_next.account_id, accounts_dm_next.product_type_id, accounts_dm_next.base_currency_code, accounts_dm_next.is_restricted ]
├── stream key: [ accounts_dm_next.account_id ]
└── StreamFilter { predicate: IsNull(accounts_dm_next.closing_date) AND IsNull(accounts_dm_next.disabled_at) }
    ├── output: [ accounts_dm_next.account_id, accounts_dm_next.product_type_id, accounts_dm_next.base_currency_code, accounts_dm_next.is_restricted, accounts_dm_next.closing_date, accounts_dm_next.disabled_at ]
    ├── stream key: [ accounts_dm_next.account_id ]
    └── StreamTableScan { table: accounts_dm_next, columns: [account_id, product_type_id, base_currency_code, is_restricted, closing_date, disabled_at] }
        ├── output: [ accounts_dm_next.account_id, accounts_dm_next.product_type_id, accounts_dm_next.base_currency_code, accounts_dm_next.is_restricted, accounts_dm_next.closing_date, accounts_dm_next.disabled_at ]
        ├── stream key: [ accounts_dm_next.account_id ]
        ├── Upstream { output: [ account_id, product_type_id, base_currency_code, is_restricted, closing_date, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, product_type_id, base_currency_code, is_restricted, closing_date, disabled_at ], stream key: [] }

Fragment 37231 (Actor 742738,742737)
StreamTableScan { table: product_types_dm_next, columns: [product_type_id, type] } { output: [ product_types_dm_next.product_type_id, product_types_dm_next.type ], stream key: [ product_types_dm_next.product_type_id ] }
├── Upstream { output: [ product_type_id, type ], stream key: [] }
└── BatchPlanNode { output: [ product_type_id, type ], stream key: [] }