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

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

Enable zooming

digraph G { id="graph_412"; subgraph graph_stage_412 { id="graph_stage_412"; isCluster="true"; label="Stage 412 (skipped)"; subgraph cluster_1138 { id="cluster_1138"; isCluster="true"; label="Scan parquet "; 395 [id="node_395" labelType="html" label="FileScanRDD [395] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 396 [id="node_396" labelType="html" label="MapPartitionsRDD [396] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1097 { id="cluster_1097"; isCluster="true"; label="WholeStageCodegen (3)"; 397 [id="node_397" labelType="html" label="MapPartitionsRDD [397] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1096 { id="cluster_1096"; isCluster="true"; label="Exchange"; 398 [id="node_398" labelType="html" label="MapPartitionsRDD [398] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 399 [id="node_399" labelType="html" label="MapPartitionsRDD [399] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 395->396; 396->397; 397->398; 398->399; }

digraph G { id="graph_413"; subgraph graph_stage_413 { id="graph_stage_413"; isCluster="true"; label="Stage 413 (skipped)"; subgraph cluster_1202 { id="cluster_1202"; isCluster="true"; label="Scan parquet "; 476 [id="node_476" labelType="html" label="FileScanRDD [476] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 478 [id="node_478" labelType="html" label="MapPartitionsRDD [478] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1120 { id="cluster_1120"; isCluster="true"; label="WholeStageCodegen (21)"; 483 [id="node_483" labelType="html" label="MapPartitionsRDD [483] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1119 { id="cluster_1119"; isCluster="true"; label="Exchange"; 484 [id="node_484" labelType="html" label="MapPartitionsRDD [484] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 485 [id="node_485" labelType="html" label="MapPartitionsRDD [485] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 476->478; 478->483; 483->484; 484->485; }

digraph G { id="graph_414"; subgraph graph_stage_414 { id="graph_stage_414"; isCluster="true"; label="Stage 414 (skipped)"; subgraph cluster_1150 { id="cluster_1150"; isCluster="true"; label="Scan parquet "; 405 [id="node_405" labelType="html" label="FileScanRDD [405] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 406 [id="node_406" labelType="html" label="MapPartitionsRDD [406] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1085 { id="cluster_1085"; isCluster="true"; label="WholeStageCodegen (1)"; 407 [id="node_407" labelType="html" label="MapPartitionsRDD [407] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1084 { id="cluster_1084"; isCluster="true"; label="Exchange"; 408 [id="node_408" labelType="html" label="MapPartitionsRDD [408] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 405->406; 406->407; 407->408; }

digraph G { id="graph_415"; subgraph graph_stage_415 { id="graph_stage_415"; isCluster="true"; label="Stage 415 (skipped)"; subgraph cluster_1685 { id="cluster_1685"; isCluster="true"; label="Exchange"; 621 [id="node_621" labelType="html" label="ShuffledRowRDD [621] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1683 { id="cluster_1683"; isCluster="true"; label="Exchange"; 622 [id="node_622" labelType="html" label="MapPartitionsRDD [622] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 621->622; }

408,621

digraph G { id="graph_416"; subgraph graph_stage_416 { id="graph_stage_416"; isCluster="true"; label="Stage 416 (skipped)"; subgraph cluster_1713 { id="cluster_1713"; isCluster="true"; label="Exchange"; 635 [id="node_635" labelType="html" label="ShuffledRowRDD [635] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1705 { id="cluster_1705"; isCluster="true"; label="WholeStageCodegen (89)"; 636 [id="node_636" labelType="html" label="MapPartitionsRDD [636] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1704 { id="cluster_1704"; isCluster="true"; label="Exchange"; 637 [id="node_637" labelType="html" label="MapPartitionsRDD [637] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 635->636; 636->637; }

485,635

digraph G { id="graph_417"; subgraph graph_stage_417 { id="graph_stage_417"; isCluster="true"; label="Stage 417 (skipped)"; subgraph cluster_1794 { id="cluster_1794"; isCluster="true"; label="Exchange"; 643 [id="node_643" labelType="html" label="ShuffledRowRDD [643] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1857 { id="cluster_1857"; isCluster="true"; label="WholeStageCodegen (169)"; 677 [id="node_677" labelType="html" label="MapPartitionsRDD [677] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1868 { id="cluster_1868"; isCluster="true"; label="Exchange"; 678 [id="node_678" labelType="html" label="ShuffledRowRDD [678] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1864 { id="cluster_1864"; isCluster="true"; label="WholeStageCodegen (170)"; 679 [id="node_679" labelType="html" label="MapPartitionsRDD [679] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1854 { id="cluster_1854"; isCluster="true"; label="WholeStageCodegen (171)"; 680 [id="node_680" labelType="html" label="ZippedPartitionsRDD2 [680] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 681 [id="node_681" labelType="html" label="MapPartitionsRDD [681] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1853 { id="cluster_1853"; isCluster="true"; label="Exchange"; 682 [id="node_682" labelType="html" label="MapPartitionsRDD [682] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 643->677; 678->679; 677->680; 679->680; 680->681; 681->682; }

622,643

637,678

digraph G { id="graph_418"; subgraph graph_stage_418 { id="graph_stage_418"; isCluster="true"; label="Stage 418 (skipped)"; subgraph cluster_1694 { id="cluster_1694"; isCluster="true"; label="Exchange"; 623 [id="node_623" labelType="html" label="ShuffledRowRDD [623] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1692 { id="cluster_1692"; isCluster="true"; label="Exchange"; 624 [id="node_624" labelType="html" label="MapPartitionsRDD [624] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 623->624; }

399,623

digraph G { id="graph_419"; subgraph graph_stage_419 { id="graph_stage_419"; isCluster="true"; label="Stage 419"; subgraph cluster_1851 { id="cluster_1851"; isCluster="true"; label="Exchange"; 670 [id="node_670" labelType="html" label="ShuffledRowRDD [670] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2071 { id="cluster_2071"; isCluster="true"; label="Exchange"; 727 [id="node_727" labelType="html" label="ShuffledRowRDD [727] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2066 { id="cluster_2066"; isCluster="true"; label="WholeStageCodegen (266)"; 728 [id="node_728" labelType="html" label="MapPartitionsRDD [728] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2073 { id="cluster_2073"; isCluster="true"; label="WholeStageCodegen (267)"; 729 [id="node_729" labelType="html" label="MapPartitionsRDD [729] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2063 { id="cluster_2063"; isCluster="true"; label="WholeStageCodegen (268)"; 730 [id="node_730" labelType="html" label="ZippedPartitionsRDD2 [730] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 731 [id="node_731" labelType="html" label="MapPartitionsRDD [731] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2062 { id="cluster_2062"; isCluster="true"; label="Project"; 732 [id="node_732" labelType="html" label="MapPartitionsRDD [732] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2033 { id="cluster_2033"; isCluster="true"; label="WholeStageCodegen (269)"; 733 [id="node_733" labelType="html" label="MapPartitionsRDD [733] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2032 { id="cluster_2032"; isCluster="true"; label="ObjectHashAggregate"; 734 [id="node_734" labelType="html" label="MapPartitionsRDD [734] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2031 { id="cluster_2031"; isCluster="true"; label="ObjectHashAggregate"; 735 [id="node_735" labelType="html" label="MapPartitionsRDD [735] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2017 { id="cluster_2017"; isCluster="true"; label="WholeStageCodegen (270)"; 736 [id="node_736" labelType="html" label="MapPartitionsRDD [736] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2016 { id="cluster_2016"; isCluster="true"; label="Exchange"; 737 [id="node_737" labelType="html" label="MapPartitionsRDD [737] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 727->728; 670->729; 728->730; 729->730; 730->731; 731->732; 732->733; 733->734; 734->735; 735->736; 736->737; }

624,670

682,727

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
419	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:58	2 s	37/37			10.1 MiB	555.8 KiB

Page:

Skipped Stages (7)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
418	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
417	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
416	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
415	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
414	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
413	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
412	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

Page: