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

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

Enable zooming

digraph G { id="graph_390"; subgraph graph_stage_390 { id="graph_stage_390"; isCluster="true"; label="Stage 390 (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_391"; subgraph graph_stage_391 { id="graph_stage_391"; isCluster="true"; label="Stage 391 (skipped)"; subgraph cluster_1145 { id="cluster_1145"; isCluster="true"; label="Scan parquet "; 473 [id="node_473" labelType="html" label="FileScanRDD [473] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 477 [id="node_477" labelType="html" label="MapPartitionsRDD [477] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1110 { id="cluster_1110"; isCluster="true"; label="WholeStageCodegen (6)"; 481 [id="node_481" labelType="html" label="MapPartitionsRDD [481] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1109 { id="cluster_1109"; isCluster="true"; label="Exchange"; 482 [id="node_482" labelType="html" label="MapPartitionsRDD [482] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 473->477; 477->481; 481->482; }

digraph G { id="graph_392"; subgraph graph_stage_392 { id="graph_stage_392"; isCluster="true"; label="Stage 392 (skipped)"; subgraph cluster_1125 { id="cluster_1125"; isCluster="true"; label="Scan parquet "; 385 [id="node_385" labelType="html" label="FileScanRDD [385] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 386 [id="node_386" labelType="html" label="MapPartitionsRDD [386] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1091 { id="cluster_1091"; isCluster="true"; label="WholeStageCodegen (2)"; 387 [id="node_387" labelType="html" label="MapPartitionsRDD [387] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1090 { id="cluster_1090"; isCluster="true"; label="Exchange"; 388 [id="node_388" labelType="html" label="MapPartitionsRDD [388] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 389 [id="node_389" labelType="html" label="MapPartitionsRDD [389] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 385->386; 386->387; 387->388; 388->389; }

digraph G { id="graph_393"; subgraph graph_stage_393 { id="graph_stage_393"; isCluster="true"; label="Stage 393 (skipped)"; subgraph cluster_1709 { id="cluster_1709"; isCluster="true"; label="Exchange"; 629 [id="node_629" labelType="html" label="ShuffledRowRDD [629] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1688 { id="cluster_1688"; isCluster="true"; label="WholeStageCodegen (82)"; 630 [id="node_630" labelType="html" label="MapPartitionsRDD [630] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1687 { id="cluster_1687"; isCluster="true"; label="Exchange"; 631 [id="node_631" labelType="html" label="MapPartitionsRDD [631] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 629->630; 630->631; }

389,629

digraph G { id="graph_394"; subgraph graph_stage_394 { id="graph_stage_394"; isCluster="true"; label="Stage 394 (skipped)"; subgraph cluster_1698 { id="cluster_1698"; isCluster="true"; label="Exchange"; 625 [id="node_625" labelType="html" label="ShuffledRowRDD [625] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1696 { id="cluster_1696"; isCluster="true"; label="Exchange"; 626 [id="node_626" labelType="html" label="MapPartitionsRDD [626] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 625->626; }

482,625

digraph G { id="graph_395"; subgraph graph_stage_395 { id="graph_stage_395"; isCluster="true"; label="Stage 395 (skipped)"; subgraph cluster_1800 { id="cluster_1800"; isCluster="true"; label="Exchange"; 646 [id="node_646" labelType="html" label="ShuffledRowRDD [646] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1790 { id="cluster_1790"; isCluster="true"; label="WholeStageCodegen (114)"; 650 [id="node_650" labelType="html" label="MapPartitionsRDD [650] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1820 { id="cluster_1820"; isCluster="true"; label="Exchange"; 651 [id="node_651" labelType="html" label="ShuffledRowRDD [651] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1814 { id="cluster_1814"; isCluster="true"; label="WholeStageCodegen (115)"; 655 [id="node_655" labelType="html" label="MapPartitionsRDD [655] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1764 { id="cluster_1764"; isCluster="true"; label="WholeStageCodegen (116)"; 659 [id="node_659" labelType="html" label="ZippedPartitionsRDD2 [659] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 665 [id="node_665" labelType="html" label="MapPartitionsRDD [665] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1763 { id="cluster_1763"; isCluster="true"; label="Exchange"; 667 [id="node_667" labelType="html" label="MapPartitionsRDD [667] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 646->650; 651->655; 650->659; 655->659; 659->665; 665->667; }

626,646

631,651

digraph G { id="graph_396"; subgraph graph_stage_396 { id="graph_stage_396"; isCluster="true"; label="Stage 396 (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_397"; subgraph graph_stage_397 { id="graph_stage_397"; isCluster="true"; label="Stage 397 (skipped)"; 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_1910 { id="cluster_1910"; isCluster="true"; label="Exchange"; 691 [id="node_691" labelType="html" label="ShuffledRowRDD [691] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1906 { id="cluster_1906"; isCluster="true"; label="WholeStageCodegen (179)"; 692 [id="node_692" labelType="html" label="MapPartitionsRDD [692] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1912 { id="cluster_1912"; isCluster="true"; label="WholeStageCodegen (180)"; 693 [id="node_693" labelType="html" label="MapPartitionsRDD [693] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1903 { id="cluster_1903"; isCluster="true"; label="WholeStageCodegen (181)"; 694 [id="node_694" labelType="html" label="ZippedPartitionsRDD2 [694] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 695 [id="node_695" labelType="html" label="MapPartitionsRDD [695] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1902 { id="cluster_1902"; isCluster="true"; label="Project"; 696 [id="node_696" labelType="html" label="MapPartitionsRDD [696] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1895 { id="cluster_1895"; isCluster="true"; label="WholeStageCodegen (182)"; 697 [id="node_697" labelType="html" label="MapPartitionsRDD [697] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1894 { id="cluster_1894"; isCluster="true"; label="Exchange"; 698 [id="node_698" labelType="html" label="MapPartitionsRDD [698] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 691->692; 670->693; 692->694; 693->694; 694->695; 695->696; 696->697; 697->698; }

624,670

667,691

digraph G { id="graph_399"; subgraph graph_stage_399 { id="graph_stage_399"; isCluster="true"; label="Stage 399"; subgraph cluster_1991 { id="cluster_1991"; isCluster="true"; label="AQEShuffleRead"; 708 [id="node_708" labelType="html" label="ShuffledRowRDD [708] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1965 { id="cluster_1965"; isCluster="true"; label="WholeStageCodegen (245)"; 713 [id="node_713" labelType="html" label="MapPartitionsRDD [713] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1963 { id="cluster_1963"; isCluster="true"; label="Generate"; 715 [id="node_715" labelType="html" label="MapPartitionsRDD [715] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1961 { id="cluster_1961"; isCluster="true"; label="ObjectHashAggregate"; 717 [id="node_717" labelType="html" label="MapPartitionsRDD [717] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1959 { id="cluster_1959"; isCluster="true"; label="ObjectHashAggregate"; 718 [id="node_718" labelType="html" label="MapPartitionsRDD [718] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1952 { id="cluster_1952"; isCluster="true"; label="WholeStageCodegen (246)"; 719 [id="node_719" labelType="html" label="MapPartitionsRDD [719] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1951 { id="cluster_1951"; isCluster="true"; label="Exchange"; 720 [id="node_720" labelType="html" label="MapPartitionsRDD [720] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 708->713; 713->715; 715->717; 717->718; 718->719; 719->720; }

698,708

Completed Stages (1)

Page:

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

Page:

Skipped Stages (8)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
397	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
396	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
395	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
394	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
393	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
392	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
391	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
390	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: