marketplace_asset_taxonomy_sink · explain

sink · alinma_bff.marketplace_asset_taxonomy_sink profiled over 5s

Job is idle — throughput ~0; structure shown.

Heat tree Operator graph

4 operators

Sink · alinma_bff.marketplace_asset_taxonomy_sink

0% idle 2 actors

StreamScan · marketplace_asset_taxonomy_mv_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.

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

Fragments (DESCRIBE FRAGMENTS) — click to expand

Fragment 64817 (Actor 743808,743807)
StreamSink { type: upsert, columns: [asset_id, dimension, taxonomy_node_id, node_name_en, node_name_ar, percentage, marketplace_asset_taxonomy_mv_next.asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id(hidden), marketplace_asset_taxonomy_mv_next.asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension(hidden), marketplace_asset_taxonomy_mv_next.asset_distributions_for_consumers_mv_next.effective_start_date(hidden)], downstream_pk: [marketplace_asset_taxonomy_mv_next.asset_id, marketplace_asset_taxonomy_mv_next.dimension, marketplace_asset_taxonomy_mv_next.taxonomy_node_id] }
├── output:
│   ┌── marketplace_asset_taxonomy_mv_next.asset_id
│   ├── marketplace_asset_taxonomy_mv_next.dimension
│   ├── marketplace_asset_taxonomy_mv_next.taxonomy_node_id
│   ├── marketplace_asset_taxonomy_mv_next.node_name_en
│   ├── marketplace_asset_taxonomy_mv_next.node_name_ar
│   ├── marketplace_asset_taxonomy_mv_next.percentage
│   ├── marketplace_asset_taxonomy_mv_next.asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id
│   ├── marketplace_asset_taxonomy_mv_next.asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension
│   └── marketplace_asset_taxonomy_mv_next.asset_distributions_for_consumers_mv_next.effective_start_date
├── stream key: [ marketplace_asset_taxonomy_mv_next.taxonomy_node_id, marketplace_asset_taxonomy_mv_next.asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, marketplace_asset_taxonomy_mv_next.asset_id, marketplace_asset_taxonomy_mv_next.asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, marketplace_asset_taxonomy_mv_next.asset_distributions_for_consumers_mv_next.effective_start_date ]
└── StreamTableScan { table: marketplace_asset_taxonomy_mv_next, columns: [asset_id, dimension, taxonomy_node_id, node_name_en, node_name_ar, percentage, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.effective_start_date] }
    ├── output:
    │   ┌── marketplace_asset_taxonomy_mv_next.asset_id
    │   ├── marketplace_asset_taxonomy_mv_next.dimension
    │   ├── marketplace_asset_taxonomy_mv_next.taxonomy_node_id
    │   ├── marketplace_asset_taxonomy_mv_next.node_name_en
    │   ├── marketplace_asset_taxonomy_mv_next.node_name_ar
    │   ├── marketplace_asset_taxonomy_mv_next.percentage
    │   ├── marketplace_asset_taxonomy_mv_next.asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id
    │   ├── marketplace_asset_taxonomy_mv_next.asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension
    │   └── marketplace_asset_taxonomy_mv_next.asset_distributions_for_consumers_mv_next.effective_start_date
    ├── stream key: [ marketplace_asset_taxonomy_mv_next.taxonomy_node_id, marketplace_asset_taxonomy_mv_next.asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, marketplace_asset_taxonomy_mv_next.asset_id, marketplace_asset_taxonomy_mv_next.asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, marketplace_asset_taxonomy_mv_next.asset_distributions_for_consumers_mv_next.effective_start_date ]
    ├── Upstream { output: [ asset_id, dimension, taxonomy_node_id, node_name_en, node_name_ar, percentage, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.effective_start_date ], stream key: [] }
    └── BatchPlanNode { output: [ asset_id, dimension, taxonomy_node_id, node_name_en, node_name_ar, percentage, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.effective_start_date ], stream key: [] }

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