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

← cluster authz objects subscription_progress explain
Overview Objects Graph History
table · authz.subscription_progress profiled over 5s
seconds (1–30)

Job is idle — throughput ~0; structure shown.

8 operators
Materialize · authz.subscription_progress
0% idle 2 actors
Filter · IsNotNull(rw_timestamp)
0% idle 2 actors
Union · IsNotNull(rw_timestamp)
0% idle 2 actors
UpstreamSinkUnion · IsNotNull(rw_timestamp)
1% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Dml
0% idle 2 actors
Source
0% idle 2 actors
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Materialize · authz.subscription_progress Materialize authz.subscription_prog… idle · 2 actors Filter · IsNotNull(rw_timestamp) Filter IsNotNull(rw_timestamp) idle · 2 actors Union · IsNotNull(rw_timestamp) Union IsNotNull(rw_timestamp) idle · 2 actors UpstreamSinkUnion · IsNotNull(rw_timestamp) UpstreamSinkUnion IsNotNull(rw_timestamp) idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Dml Dml idle · 2 actors Source Source idle · 2 actors
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand 
Fragment 5286 (Actor 96070,96071)
StreamMaterialize { columns: [subscription_name, rw_timestamp], stream_key: [subscription_name], pk_columns: [subscription_name], pk_conflict: Overwrite }
├── output: [ subscription_name, rw_timestamp ]
├── stream key: [ subscription_name ]
└── StreamFilter [upsert] { predicate: IsNotNull(rw_timestamp) } { output: [ subscription_name, rw_timestamp ], stream key: [] }
    └── StreamUnion { all: true } { output: [ subscription_name, rw_timestamp ], stream key: [] }
        ├── MergeExecutor { output: [ subscription_name, rw_timestamp ], stream key: [] }
        └── StreamUpstreamSinkUnion { output: [ subscription_name, rw_timestamp ], stream key: [] }

Fragment 5287 (Actor 96073,96072)
StreamDml { columns: [subscription_name, rw_timestamp] } { output: [ subscription_name, rw_timestamp ], stream key: [] }
└── StreamSource { output: [ subscription_name, rw_timestamp ], stream key: [] }