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

Status: SUCCEEDED
Submitted: 2026/04/20 06:16:32
Duration: 1 s
Associated SQL Query: 57
Job Group: 36e0914c-7e4e-3a52-bc93-e306e07299ba
Completed Stages: 1
Skipped Stages: 7

Enable zooming

digraph G { id="graph_286"; subgraph graph_stage_286 { id="graph_stage_286"; isCluster="true"; label="Stage 286 (skipped)"; subgraph cluster_1221 { id="cluster_1221"; isCluster="true"; label="Scan parquet "; 428 [id="node_428" labelType="html" label="FileScanRDD [428] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 429 [id="node_429" labelType="html" label="MapPartitionsRDD [429] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1172 { id="cluster_1172"; isCluster="true"; label="WholeStageCodegen (5)"; 432 [id="node_432" labelType="html" label="MapPartitionsRDD [432] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1171 { id="cluster_1171"; isCluster="true"; label="Exchange"; 433 [id="node_433" labelType="html" label="MapPartitionsRDD [433] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 434 [id="node_434" labelType="html" label="MapPartitionsRDD [434] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 428->429; 429->432; 432->433; 433->434; }

digraph G { id="graph_287"; subgraph graph_stage_287 { id="graph_stage_287"; isCluster="true"; label="Stage 287 (skipped)"; subgraph cluster_1193 { id="cluster_1193"; isCluster="true"; label="Scan parquet "; 430 [id="node_430" labelType="html" label="FileScanRDD [430] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 431 [id="node_431" labelType="html" label="MapPartitionsRDD [431] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1168 { id="cluster_1168"; isCluster="true"; label="WholeStageCodegen (4)"; 435 [id="node_435" labelType="html" label="MapPartitionsRDD [435] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1167 { id="cluster_1167"; isCluster="true"; label="Exchange"; 436 [id="node_436" labelType="html" label="MapPartitionsRDD [436] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 430->431; 431->435; 435->436; }

digraph G { id="graph_288"; subgraph graph_stage_288 { id="graph_stage_288"; isCluster="true"; label="Stage 288 (skipped)"; subgraph cluster_1336 { id="cluster_1336"; isCluster="true"; label="Exchange"; 502 [id="node_502" labelType="html" label="ShuffledRowRDD [502] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1334 { id="cluster_1334"; isCluster="true"; label="Exchange"; 503 [id="node_503" labelType="html" label="MapPartitionsRDD [503] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 502->503; }

436,502

digraph G { id="graph_289"; subgraph graph_stage_289 { id="graph_stage_289"; isCluster="true"; label="Stage 289 (skipped)"; subgraph cluster_1411 { id="cluster_1411"; isCluster="true"; label="Exchange"; 530 [id="node_530" labelType="html" label="ShuffledRowRDD [530] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1407 { id="cluster_1407"; isCluster="true"; label="WholeStageCodegen (58)"; 531 [id="node_531" labelType="html" label="MapPartitionsRDD [531] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1406 { id="cluster_1406"; isCluster="true"; label="Exchange"; 532 [id="node_532" labelType="html" label="MapPartitionsRDD [532] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 530->531; 531->532; }

434,530

digraph G { id="graph_290"; subgraph graph_stage_290 { id="graph_stage_290"; isCluster="true"; label="Stage 290 (skipped)"; subgraph cluster_1187 { id="cluster_1187"; isCluster="true"; label="Scan parquet "; 409 [id="node_409" labelType="html" label="FileScanRDD [409] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 410 [id="node_410" labelType="html" label="MapPartitionsRDD [410] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1157 { id="cluster_1157"; isCluster="true"; label="WholeStageCodegen (3)"; 411 [id="node_411" labelType="html" label="MapPartitionsRDD [411] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1156 { id="cluster_1156"; isCluster="true"; label="Exchange"; 412 [id="node_412" labelType="html" label="MapPartitionsRDD [412] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 413 [id="node_413" labelType="html" label="MapPartitionsRDD [413] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 409->410; 410->411; 411->412; 412->413; }

digraph G { id="graph_291"; subgraph graph_stage_291 { id="graph_stage_291"; isCluster="true"; label="Stage 291 (skipped)"; subgraph cluster_1287 { id="cluster_1287"; isCluster="true"; label="Exchange"; 496 [id="node_496" labelType="html" label="ShuffledRowRDD [496] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1285 { id="cluster_1285"; isCluster="true"; label="Exchange"; 498 [id="node_498" labelType="html" label="MapPartitionsRDD [498] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 496->498; }

413,496

digraph G { id="graph_292"; subgraph graph_stage_292 { id="graph_stage_292"; isCluster="true"; label="Stage 292 (skipped)"; subgraph cluster_1543 { id="cluster_1543"; isCluster="true"; label="Exchange"; 572 [id="node_572" labelType="html" label="ShuffledRowRDD [572] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1539 { id="cluster_1539"; isCluster="true"; label="WholeStageCodegen (87)"; 573 [id="node_573" labelType="html" label="MapPartitionsRDD [573] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1549 { id="cluster_1549"; isCluster="true"; label="Exchange"; 574 [id="node_574" labelType="html" label="ShuffledRowRDD [574] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1545 { id="cluster_1545"; isCluster="true"; label="WholeStageCodegen (88)"; 575 [id="node_575" labelType="html" label="MapPartitionsRDD [575] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1536 { id="cluster_1536"; isCluster="true"; label="WholeStageCodegen (89)"; 576 [id="node_576" labelType="html" label="ZippedPartitionsRDD2 [576] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 577 [id="node_577" labelType="html" label="MapPartitionsRDD [577] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1535 { id="cluster_1535"; isCluster="true"; label="Exchange"; 578 [id="node_578" labelType="html" label="MapPartitionsRDD [578] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 572->573; 574->575; 573->576; 575->576; 576->577; 577->578; }

503,572

532,574

digraph G { id="graph_293"; subgraph graph_stage_293 { id="graph_stage_293"; isCluster="true"; label="Stage 293"; subgraph cluster_1434 { id="cluster_1434"; isCluster="true"; label="Exchange"; 535 [id="node_535" labelType="html" label="ShuffledRowRDD [535] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1585 { id="cluster_1585"; isCluster="true"; label="Exchange"; 579 [id="node_579" labelType="html" label="ShuffledRowRDD [579] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1581 { id="cluster_1581"; isCluster="true"; label="WholeStageCodegen (90)"; 580 [id="node_580" labelType="html" label="MapPartitionsRDD [580] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1587 { id="cluster_1587"; isCluster="true"; label="WholeStageCodegen (91)"; 581 [id="node_581" labelType="html" label="MapPartitionsRDD [581] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1578 { id="cluster_1578"; isCluster="true"; label="WholeStageCodegen (92)"; 582 [id="node_582" labelType="html" label="ZippedPartitionsRDD2 [582] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 583 [id="node_583" labelType="html" label="MapPartitionsRDD [583] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1577 { id="cluster_1577"; isCluster="true"; label="Project"; 584 [id="node_584" labelType="html" label="MapPartitionsRDD [584] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1564 { id="cluster_1564"; isCluster="true"; label="WholeStageCodegen (93)"; 585 [id="node_585" labelType="html" label="MapPartitionsRDD [585] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1563 { id="cluster_1563"; isCluster="true"; label="ObjectHashAggregate"; 586 [id="node_586" labelType="html" label="MapPartitionsRDD [586] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1562 { id="cluster_1562"; isCluster="true"; label="ObjectHashAggregate"; 587 [id="node_587" labelType="html" label="MapPartitionsRDD [587] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1552 { id="cluster_1552"; isCluster="true"; label="WholeStageCodegen (94)"; 588 [id="node_588" labelType="html" label="MapPartitionsRDD [588] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1551 { id="cluster_1551"; isCluster="true"; label="Exchange"; 589 [id="node_589" labelType="html" label="MapPartitionsRDD [589] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 579->580; 535->581; 580->582; 581->582; 582->583; 583->584; 584->585; 585->586; 586->587; 587->588; 588->589; }

498,535

578,579

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
293	tenants-pool-506	replenishmentRunId = 10000000004 tenantId = 8793759653749352888 activityType = BufferDataSnapShot activityId = 36e0914c-7e4e-3a52-bc93-e306e07299ba workflowType = KpiPrepareDataSnapshotWorkflow workflowId = b49fb3c6-88b3-3c61-97e8-cbe3f98f9409 attempt = 1 cornerstoneTenantId = 8445 marketUnit = 10000_OP_PERF 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/20 06:16:32	1 s	37/37			10.1 MiB	555.8 KiB

Page:

Skipped Stages (7)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
292	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/37
291	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/37
290	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/2
289	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/37
288	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/37
287	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/37
286	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/37

Page: