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

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

Enable zooming

digraph G { id="graph_456"; subgraph graph_stage_456 { id="graph_stage_456"; isCluster="true"; label="Stage 456 (skipped)"; subgraph cluster_2252 { id="cluster_2252"; isCluster="true"; label="LocalTableScan"; 781 [id="node_781" labelType="html" label="ParallelCollectionRDD [781] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 784 [id="node_784" labelType="html" label="MapPartitionsRDD [784] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2251 { id="cluster_2251"; isCluster="true"; label="Exchange"; 785 [id="node_785" labelType="html" label="MapPartitionsRDD [785] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 781->784; 784->785; }

digraph G { id="graph_457"; subgraph graph_stage_457 { id="graph_stage_457"; isCluster="true"; label="Stage 457 (skipped)"; subgraph cluster_2246 { id="cluster_2246"; isCluster="true"; label="LocalTableScan"; 786 [id="node_786" labelType="html" label="ParallelCollectionRDD [786] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 787 [id="node_787" labelType="html" label="MapPartitionsRDD [787] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2245 { id="cluster_2245"; isCluster="true"; label="Exchange"; 788 [id="node_788" labelType="html" label="MapPartitionsRDD [788] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 786->787; 787->788; }

digraph G { id="graph_458"; subgraph graph_stage_458 { id="graph_stage_458"; isCluster="true"; label="Stage 458 (skipped)"; subgraph cluster_2249 { id="cluster_2249"; isCluster="true"; label="LocalTableScan"; 780 [id="node_780" labelType="html" label="ParallelCollectionRDD [780] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 782 [id="node_782" labelType="html" label="MapPartitionsRDD [782] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2248 { id="cluster_2248"; isCluster="true"; label="Exchange"; 783 [id="node_783" labelType="html" label="MapPartitionsRDD [783] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 780->782; 782->783; }

digraph G { id="graph_459"; subgraph graph_stage_459 { id="graph_stage_459"; isCluster="true"; label="Stage 459 (skipped)"; subgraph cluster_2262 { id="cluster_2262"; isCluster="true"; label="AQEShuffleRead"; 789 [id="node_789" labelType="html" label="ShuffledRowRDD [789] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2259 { id="cluster_2259"; isCluster="true"; label="WholeStageCodegen (1)"; 790 [id="node_790" labelType="html" label="MapPartitionsRDD [790] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2267 { id="cluster_2267"; isCluster="true"; label="AQEShuffleRead"; 791 [id="node_791" labelType="html" label="ShuffledRowRDD [791] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2264 { id="cluster_2264"; isCluster="true"; label="WholeStageCodegen (2)"; 792 [id="node_792" labelType="html" label="MapPartitionsRDD [792] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2255 { id="cluster_2255"; isCluster="true"; label="WholeStageCodegen (3)"; 793 [id="node_793" labelType="html" label="ZippedPartitionsRDD2 [793] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 794 [id="node_794" labelType="html" label="MapPartitionsRDD [794] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2254 { id="cluster_2254"; isCluster="true"; label="Exchange"; 795 [id="node_795" labelType="html" label="MapPartitionsRDD [795] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 789->790; 791->792; 790->793; 792->793; 793->794; 794->795; }

788,789

783,791

digraph G { id="graph_460"; subgraph graph_stage_460 { id="graph_stage_460"; isCluster="true"; label="Stage 460"; subgraph cluster_2277 { id="cluster_2277"; isCluster="true"; label="AQEShuffleRead"; 796 [id="node_796" labelType="html" label="ShuffledRowRDD [796] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2274 { id="cluster_2274"; isCluster="true"; label="WholeStageCodegen (4)"; 797 [id="node_797" labelType="html" label="MapPartitionsRDD [797] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2282 { id="cluster_2282"; isCluster="true"; label="AQEShuffleRead"; 798 [id="node_798" labelType="html" label="ShuffledRowRDD [798] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2279 { id="cluster_2279"; isCluster="true"; label="WholeStageCodegen (5)"; 799 [id="node_799" labelType="html" label="MapPartitionsRDD [799] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2269 { id="cluster_2269"; isCluster="true"; label="WholeStageCodegen (6)"; 800 [id="node_800" labelType="html" label="ZippedPartitionsRDD2 [800] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 801 [id="node_801" labelType="html" label="MapPartitionsRDD [801] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2268 { id="cluster_2268"; isCluster="true"; label="WriteFiles"; 802 [id="node_802" labelType="html" label="MapPartitionsRDD [802] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 796->797; 798->799; 797->800; 799->800; 800->801; 801->802; }

795,796

785,798

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
460	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:17:04	1 s	1/1		52.7 KiB	40.2 KiB

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
459	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/1
458	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
457	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
456	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: