crp-order-quantity-kpi-service - Details for Job 24

Status: SUCCEEDED
Submitted: 2026/04/11 14:40:30
Duration: 1 s
Associated SQL Query: 18
Job Group: 0221f660-f20c-3ec8-a242-7de8ba8fb864
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_41"; subgraph graph_stage_41 { id="graph_stage_41"; isCluster="true"; label="Stage 41 (skipped)"; subgraph cluster_281 { id="cluster_281"; isCluster="true"; label="LocalTableScan"; 123 [id="node_123" labelType="html" label="ParallelCollectionRDD [123] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 124 [id="node_124" labelType="html" label="MapPartitionsRDD [124] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_280 { id="cluster_280"; isCluster="true"; label="Exchange"; 125 [id="node_125" labelType="html" label="MapPartitionsRDD [125] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 123->124; 124->125; }

digraph G { id="graph_42"; subgraph graph_stage_42 { id="graph_stage_42"; isCluster="true"; label="Stage 42 (skipped)"; subgraph cluster_284 { id="cluster_284"; isCluster="true"; label="LocalTableScan"; 118 [id="node_118" labelType="html" label="ParallelCollectionRDD [118] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 119 [id="node_119" labelType="html" label="MapPartitionsRDD [119] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_283 { id="cluster_283"; isCluster="true"; label="Exchange"; 121 [id="node_121" labelType="html" label="MapPartitionsRDD [121] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 118->119; 119->121; }

digraph G { id="graph_43"; subgraph graph_stage_43 { id="graph_stage_43"; isCluster="true"; label="Stage 43 (skipped)"; subgraph cluster_297 { id="cluster_297"; isCluster="true"; label="AQEShuffleRead"; 126 [id="node_126" labelType="html" label="ShuffledRowRDD [126] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_294 { id="cluster_294"; isCluster="true"; label="WholeStageCodegen (1)"; 127 [id="node_127" labelType="html" label="MapPartitionsRDD [127] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_302 { id="cluster_302"; isCluster="true"; label="AQEShuffleRead"; 128 [id="node_128" labelType="html" label="ShuffledRowRDD [128] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_299 { id="cluster_299"; isCluster="true"; label="WholeStageCodegen (2)"; 129 [id="node_129" labelType="html" label="MapPartitionsRDD [129] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_290 { id="cluster_290"; isCluster="true"; label="WholeStageCodegen (3)"; 130 [id="node_130" labelType="html" label="ZippedPartitionsRDD2 [130] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 131 [id="node_131" labelType="html" label="MapPartitionsRDD [131] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_289 { id="cluster_289"; isCluster="true"; label="Exchange"; 132 [id="node_132" labelType="html" label="MapPartitionsRDD [132] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 126->127; 128->129; 127->130; 129->130; 130->131; 131->132; }

125,126

121,128

digraph G { id="graph_44"; subgraph graph_stage_44 { id="graph_stage_44"; isCluster="true"; label="Stage 44 (skipped)"; subgraph cluster_287 { id="cluster_287"; isCluster="true"; label="LocalTableScan"; 117 [id="node_117" labelType="html" label="ParallelCollectionRDD [117] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 120 [id="node_120" labelType="html" label="MapPartitionsRDD [120] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_286 { id="cluster_286"; isCluster="true"; label="Exchange"; 122 [id="node_122" labelType="html" label="MapPartitionsRDD [122] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 117->120; 120->122; }

digraph G { id="graph_45"; subgraph graph_stage_45 { id="graph_stage_45"; isCluster="true"; label="Stage 45"; subgraph cluster_312 { id="cluster_312"; isCluster="true"; label="AQEShuffleRead"; 133 [id="node_133" labelType="html" label="ShuffledRowRDD [133] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_309 { id="cluster_309"; isCluster="true"; label="WholeStageCodegen (4)"; 134 [id="node_134" labelType="html" label="MapPartitionsRDD [134] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_317 { id="cluster_317"; isCluster="true"; label="AQEShuffleRead"; 135 [id="node_135" labelType="html" label="ShuffledRowRDD [135] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_314 { id="cluster_314"; isCluster="true"; label="WholeStageCodegen (5)"; 136 [id="node_136" labelType="html" label="MapPartitionsRDD [136] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_304 { id="cluster_304"; isCluster="true"; label="WholeStageCodegen (6)"; 137 [id="node_137" labelType="html" label="ZippedPartitionsRDD2 [137] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 138 [id="node_138" labelType="html" label="MapPartitionsRDD [138] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_303 { id="cluster_303"; isCluster="true"; label="WriteFiles"; 139 [id="node_139" labelType="html" label="MapPartitionsRDD [139] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 133->134; 135->136; 134->137; 136->137; 137->138; 138->139; }

132,133

122,135

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
45	tenants-pool-286	replenishmentRunId = 10000000120 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = 0221f660-f20c-3ec8-a242-7de8ba8fb864 workflowType = CalculateOrderProposalsWorkflow workflowId = 7421d6c7-702b-33bf-84ff-d21f3533b79c 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/04/11 14:40:30	1 s	1/1		29.4 KiB	268.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
44	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
43	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
42	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
41	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: