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

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

Enable zooming

digraph G { id="graph_400"; subgraph graph_stage_400 { id="graph_stage_400"; isCluster="true"; label="Stage 400"; 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_401"; subgraph graph_stage_401 { id="graph_stage_401"; isCluster="true"; label="Stage 401"; 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_402"; subgraph graph_stage_402 { id="graph_stage_402"; isCluster="true"; label="Stage 402 (skipped)"; subgraph cluster_1647 { id="cluster_1647"; isCluster="true"; label="Scan parquet "; 608 [id="node_608" labelType="html" label="FileScanRDD [608] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 609 [id="node_609" labelType="html" label="MapPartitionsRDD [609] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1637 { id="cluster_1637"; isCluster="true"; label="WholeStageCodegen (41)"; 610 [id="node_610" labelType="html" label="MapPartitionsRDD [610] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1636 { id="cluster_1636"; isCluster="true"; label="Exchange"; 611 [id="node_611" labelType="html" label="MapPartitionsRDD [611] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 608->609; 609->610; 610->611; }

digraph G { id="graph_403"; subgraph graph_stage_403 { id="graph_stage_403"; isCluster="true"; label="Stage 403 (skipped)"; subgraph cluster_1756 { id="cluster_1756"; isCluster="true"; label="Exchange"; 641 [id="node_641" labelType="html" label="ShuffledRowRDD [641] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1754 { id="cluster_1754"; isCluster="true"; label="Exchange"; 642 [id="node_642" labelType="html" label="MapPartitionsRDD [642] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 641->642; }

611,641

digraph G { id="graph_404"; subgraph graph_stage_404 { id="graph_stage_404"; isCluster="true"; label="Stage 404"; 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_405"; subgraph graph_stage_405 { id="graph_stage_405"; isCluster="true"; label="Stage 405 (skipped)"; subgraph cluster_1796 { id="cluster_1796"; isCluster="true"; label="Exchange"; 644 [id="node_644" labelType="html" label="ShuffledRowRDD [644] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1779 { id="cluster_1779"; isCluster="true"; label="WholeStageCodegen (138)"; 649 [id="node_649" labelType="html" label="MapPartitionsRDD [649] [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_1807 { id="cluster_1807"; isCluster="true"; label="WholeStageCodegen (139)"; 654 [id="node_654" labelType="html" label="MapPartitionsRDD [654] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1774 { id="cluster_1774"; isCluster="true"; label="WholeStageCodegen (140)"; 658 [id="node_658" labelType="html" label="ZippedPartitionsRDD2 [658] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 663 [id="node_663" labelType="html" label="MapPartitionsRDD [663] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1773 { id="cluster_1773"; isCluster="true"; label="Exchange"; 666 [id="node_666" labelType="html" label="MapPartitionsRDD [666] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 644->649; 651->654; 649->658; 654->658; 658->663; 663->666; }

642,644

631,651

digraph G { id="graph_406"; subgraph graph_stage_406 { id="graph_stage_406"; isCluster="true"; label="Stage 406"; 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_407"; subgraph graph_stage_407 { id="graph_stage_407"; isCluster="true"; label="Stage 407 (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_1885 { id="cluster_1885"; isCluster="true"; label="Exchange"; 683 [id="node_683" labelType="html" label="ShuffledRowRDD [683] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1881 { id="cluster_1881"; isCluster="true"; label="WholeStageCodegen (175)"; 684 [id="node_684" labelType="html" label="MapPartitionsRDD [684] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1887 { id="cluster_1887"; isCluster="true"; label="WholeStageCodegen (176)"; 685 [id="node_685" labelType="html" label="MapPartitionsRDD [685] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1878 { id="cluster_1878"; isCluster="true"; label="WholeStageCodegen (177)"; 686 [id="node_686" labelType="html" label="ZippedPartitionsRDD2 [686] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 687 [id="node_687" labelType="html" label="MapPartitionsRDD [687] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1877 { id="cluster_1877"; isCluster="true"; label="Project"; 688 [id="node_688" labelType="html" label="MapPartitionsRDD [688] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1871 { id="cluster_1871"; isCluster="true"; label="WholeStageCodegen (178)"; 689 [id="node_689" labelType="html" label="MapPartitionsRDD [689] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1870 { id="cluster_1870"; isCluster="true"; label="Exchange"; 690 [id="node_690" labelType="html" label="MapPartitionsRDD [690] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 683->684; 670->685; 684->686; 685->686; 686->687; 687->688; 688->689; 689->690; }

624,670

666,683

digraph G { id="graph_408"; subgraph graph_stage_408 { id="graph_stage_408"; isCluster="true"; label="Stage 408"; subgraph cluster_2004 { id="cluster_2004"; isCluster="true"; label="AQEShuffleRead"; 721 [id="node_721" labelType="html" label="ShuffledRowRDD [721] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2000 { id="cluster_2000"; isCluster="true"; label="WholeStageCodegen (260)"; 723 [id="node_723" labelType="html" label="MapPartitionsRDD [723] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1999 { id="cluster_1999"; isCluster="true"; label="Exchange"; 724 [id="node_724" labelType="html" label="MapPartitionsRDD [724] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 721->723; 723->724; }

690,721

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
408	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:56	0.1 s	9/9			558.2 KiB	607.3 KiB

Page:

Skipped Stages (8)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
407	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
406	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
405	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
404	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
403	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
402	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
401	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
400	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: