crp-order-quantity-kpi-service

Status: SUCCEEDED
Submitted: 2026/02/06 06:55:10
Duration: 2 s
Associated SQL Query: 5
Job Group: f7c8bcdf-0636-3283-a6d4-2f6723afc071
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_7"; subgraph graph_stage_7 { id="graph_stage_7"; isCluster="true"; label="Stage 7 (skipped)"; subgraph cluster_31 { id="cluster_31"; isCluster="true"; label="LocalTableScan"; 22 [id="node_22" labelType="html" label="ParallelCollectionRDD [22] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 23 [id="node_23" labelType="html" label="MapPartitionsRDD [23] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_30 { id="cluster_30"; isCluster="true"; label="Exchange"; 24 [id="node_24" labelType="html" label="MapPartitionsRDD [24] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 22->23; 23->24; }

digraph G { id="graph_8"; subgraph graph_stage_8 { id="graph_stage_8"; isCluster="true"; label="Stage 8 (skipped)"; subgraph cluster_34 { id="cluster_34"; isCluster="true"; label="LocalTableScan"; 17 [id="node_17" labelType="html" label="ParallelCollectionRDD [17] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 18 [id="node_18" labelType="html" label="MapPartitionsRDD [18] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_33 { id="cluster_33"; isCluster="true"; label="Exchange"; 20 [id="node_20" labelType="html" label="MapPartitionsRDD [20] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 17->18; 18->20; }

digraph G { id="graph_9"; subgraph graph_stage_9 { id="graph_stage_9"; isCluster="true"; label="Stage 9 (skipped)"; subgraph cluster_47 { id="cluster_47"; isCluster="true"; label="AQEShuffleRead"; 25 [id="node_25" labelType="html" label="ShuffledRowRDD [25] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_44 { id="cluster_44"; isCluster="true"; label="WholeStageCodegen (1)"; 26 [id="node_26" labelType="html" label="MapPartitionsRDD [26] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_52 { id="cluster_52"; isCluster="true"; label="AQEShuffleRead"; 27 [id="node_27" labelType="html" label="ShuffledRowRDD [27] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_49 { id="cluster_49"; isCluster="true"; label="WholeStageCodegen (2)"; 28 [id="node_28" labelType="html" label="MapPartitionsRDD [28] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_40 { id="cluster_40"; isCluster="true"; label="WholeStageCodegen (3)"; 29 [id="node_29" labelType="html" label="ZippedPartitionsRDD2 [29] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 30 [id="node_30" labelType="html" label="MapPartitionsRDD [30] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_39 { id="cluster_39"; isCluster="true"; label="Exchange"; 31 [id="node_31" labelType="html" label="MapPartitionsRDD [31] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 25->26; 27->28; 26->29; 28->29; 29->30; 30->31; }

24,25

20,27

digraph G { id="graph_10"; subgraph graph_stage_10 { id="graph_stage_10"; isCluster="true"; label="Stage 10 (skipped)"; subgraph cluster_37 { id="cluster_37"; isCluster="true"; label="LocalTableScan"; 16 [id="node_16" labelType="html" label="ParallelCollectionRDD [16] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 19 [id="node_19" labelType="html" label="MapPartitionsRDD [19] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_36 { id="cluster_36"; isCluster="true"; label="Exchange"; 21 [id="node_21" labelType="html" label="MapPartitionsRDD [21] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 16->19; 19->21; }

digraph G { id="graph_11"; subgraph graph_stage_11 { id="graph_stage_11"; isCluster="true"; label="Stage 11"; subgraph cluster_62 { id="cluster_62"; isCluster="true"; label="AQEShuffleRead"; 32 [id="node_32" labelType="html" label="ShuffledRowRDD [32] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_59 { id="cluster_59"; isCluster="true"; label="WholeStageCodegen (4)"; 33 [id="node_33" labelType="html" label="MapPartitionsRDD [33] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_67 { id="cluster_67"; isCluster="true"; label="AQEShuffleRead"; 34 [id="node_34" labelType="html" label="ShuffledRowRDD [34] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_64 { id="cluster_64"; isCluster="true"; label="WholeStageCodegen (5)"; 35 [id="node_35" labelType="html" label="MapPartitionsRDD [35] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_54 { id="cluster_54"; isCluster="true"; label="WholeStageCodegen (6)"; 36 [id="node_36" labelType="html" label="ZippedPartitionsRDD2 [36] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 37 [id="node_37" labelType="html" label="MapPartitionsRDD [37] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_53 { id="cluster_53"; isCluster="true"; label="WriteFiles"; 38 [id="node_38" labelType="html" label="MapPartitionsRDD [38] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 32->33; 34->35; 33->36; 35->36; 36->37; 37->38; }

31,32

21,34

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
11	tenants-pool-286	replenishmentRunId = 10000000095 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = f7c8bcdf-0636-3283-a6d4-2f6723afc071 workflowType = CalculateOrderProposalsWorkflow workflowId = eba25ea7-bf45-3f36-ad32-cdab1a2c01e5 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:10	2 s	1/1		29.4 KiB	295.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
10	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
9	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
8	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
7	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1

Page:

Details for Job 7

Completed Stages (1)

Skipped Stages (4)