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

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

Enable zooming

digraph G { id="graph_271"; subgraph graph_stage_271 { id="graph_stage_271"; isCluster="true"; label="Stage 271 (skipped)"; subgraph cluster_1212 { id="cluster_1212"; isCluster="true"; label="Scan parquet "; 441 [id="node_441" labelType="html" label="FileScanRDD [441] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 442 [id="node_442" labelType="html" label="MapPartitionsRDD [442] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1206 { id="cluster_1206"; isCluster="true"; label="WholeStageCodegen (9)"; 445 [id="node_445" labelType="html" label="MapPartitionsRDD [445] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1205 { id="cluster_1205"; isCluster="true"; label="Exchange"; 446 [id="node_446" labelType="html" label="MapPartitionsRDD [446] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 441->442; 442->445; 445->446; }

digraph G { id="graph_272"; subgraph graph_stage_272 { id="graph_stage_272"; isCluster="true"; label="Stage 272 (skipped)"; subgraph cluster_1191 { id="cluster_1191"; isCluster="true"; label="Scan parquet "; 415 [id="node_415" labelType="html" label="FileScanRDD [415] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 417 [id="node_417" labelType="html" label="MapPartitionsRDD [417] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1163 { id="cluster_1163"; isCluster="true"; label="WholeStageCodegen (2)"; 420 [id="node_420" labelType="html" label="MapPartitionsRDD [420] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1161 { id="cluster_1161"; isCluster="true"; label="Exchange"; 421 [id="node_421" labelType="html" label="MapPartitionsRDD [421] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 422 [id="node_422" labelType="html" label="MapPartitionsRDD [422] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 415->417; 417->420; 420->421; 421->422; }

digraph G { id="graph_273"; subgraph graph_stage_273 { id="graph_stage_273"; isCluster="true"; label="Stage 273 (skipped)"; subgraph cluster_1351 { id="cluster_1351"; isCluster="true"; label="Exchange"; 508 [id="node_508" labelType="html" label="ShuffledRowRDD [508] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1347 { id="cluster_1347"; isCluster="true"; label="WholeStageCodegen (34)"; 509 [id="node_509" labelType="html" label="MapPartitionsRDD [509] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1346 { id="cluster_1346"; isCluster="true"; label="Exchange"; 510 [id="node_510" labelType="html" label="MapPartitionsRDD [510] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 508->509; 509->510; }

422,508

digraph G { id="graph_274"; subgraph graph_stage_274 { id="graph_stage_274"; isCluster="true"; label="Stage 274 (skipped)"; subgraph cluster_1340 { id="cluster_1340"; isCluster="true"; label="Exchange"; 504 [id="node_504" labelType="html" label="ShuffledRowRDD [504] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1338 { id="cluster_1338"; isCluster="true"; label="Exchange"; 505 [id="node_505" labelType="html" label="MapPartitionsRDD [505] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 504->505; }

446,504

digraph G { id="graph_275"; subgraph graph_stage_275 { id="graph_stage_275"; isCluster="true"; label="Stage 275 (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_276"; subgraph graph_stage_276 { id="graph_stage_276"; isCluster="true"; label="Stage 276 (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_277"; subgraph graph_stage_277 { id="graph_stage_277"; isCluster="true"; label="Stage 277 (skipped)"; subgraph cluster_1384 { id="cluster_1384"; isCluster="true"; label="Exchange"; 513 [id="node_513" labelType="html" label="ShuffledRowRDD [513] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1372 { id="cluster_1372"; isCluster="true"; label="WholeStageCodegen (43)"; 516 [id="node_516" labelType="html" label="MapPartitionsRDD [516] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1399 { id="cluster_1399"; isCluster="true"; label="Exchange"; 517 [id="node_517" labelType="html" label="ShuffledRowRDD [517] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1387 { id="cluster_1387"; isCluster="true"; label="WholeStageCodegen (44)"; 523 [id="node_523" labelType="html" label="MapPartitionsRDD [523] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1359 { id="cluster_1359"; isCluster="true"; label="WholeStageCodegen (45)"; 525 [id="node_525" labelType="html" label="ZippedPartitionsRDD2 [525] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 527 [id="node_527" labelType="html" label="MapPartitionsRDD [527] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1358 { id="cluster_1358"; isCluster="true"; label="Exchange"; 529 [id="node_529" labelType="html" label="MapPartitionsRDD [529] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 513->516; 517->523; 516->525; 523->525; 525->527; 527->529; }

505,513

510,517

digraph G { id="graph_278"; subgraph graph_stage_278 { id="graph_stage_278"; isCluster="true"; label="Stage 278 (skipped)"; 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_1476 { id="cluster_1476"; isCluster="true"; label="Exchange"; 550 [id="node_550" labelType="html" label="ShuffledRowRDD [550] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1472 { id="cluster_1472"; isCluster="true"; label="WholeStageCodegen (71)"; 551 [id="node_551" labelType="html" label="MapPartitionsRDD [551] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1478 { id="cluster_1478"; isCluster="true"; label="WholeStageCodegen (72)"; 552 [id="node_552" labelType="html" label="MapPartitionsRDD [552] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1469 { id="cluster_1469"; isCluster="true"; label="WholeStageCodegen (73)"; 553 [id="node_553" labelType="html" label="ZippedPartitionsRDD2 [553] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 554 [id="node_554" labelType="html" label="MapPartitionsRDD [554] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1468 { id="cluster_1468"; isCluster="true"; label="Project"; 555 [id="node_555" labelType="html" label="MapPartitionsRDD [555] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1461 { id="cluster_1461"; isCluster="true"; label="WholeStageCodegen (74)"; 556 [id="node_556" labelType="html" label="MapPartitionsRDD [556] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1460 { id="cluster_1460"; isCluster="true"; label="Exchange"; 557 [id="node_557" labelType="html" label="MapPartitionsRDD [557] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 550->551; 535->552; 551->553; 552->553; 553->554; 554->555; 555->556; 556->557; }

498,535

529,550

digraph G { id="graph_279"; subgraph graph_stage_279 { id="graph_stage_279"; isCluster="true"; label="Stage 279"; subgraph cluster_1533 { id="cluster_1533"; isCluster="true"; label="AQEShuffleRead"; 559 [id="node_559" labelType="html" label="ShuffledRowRDD [559] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1510 { id="cluster_1510"; isCluster="true"; label="WholeStageCodegen (83)"; 561 [id="node_561" labelType="html" label="MapPartitionsRDD [561] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1508 { id="cluster_1508"; isCluster="true"; label="Generate"; 563 [id="node_563" labelType="html" label="MapPartitionsRDD [563] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1506 { id="cluster_1506"; isCluster="true"; label="ObjectHashAggregate"; 565 [id="node_565" labelType="html" label="MapPartitionsRDD [565] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1504 { id="cluster_1504"; isCluster="true"; label="ObjectHashAggregate"; 567 [id="node_567" labelType="html" label="MapPartitionsRDD [567] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1486 { id="cluster_1486"; isCluster="true"; label="WholeStageCodegen (84)"; 568 [id="node_568" labelType="html" label="MapPartitionsRDD [568] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1485 { id="cluster_1485"; isCluster="true"; label="Exchange"; 571 [id="node_571" labelType="html" label="MapPartitionsRDD [571] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 559->561; 561->563; 563->565; 565->567; 567->568; 568->571; }

557,559

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
279	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:19	0.3 s	4/4			208.6 KiB

Page:

Skipped Stages (8)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
278	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
277	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
276	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
275	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
274	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
273	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
272	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
271	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: