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

Status: SUCCEEDED
Submitted: 2026/07/19 17:56:22
Duration: 1 s
Associated SQL Query: 144
Job Group: 88345701-fac2-32a9-a12c-ae48baa9a002
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_347"; subgraph graph_stage_347 { id="graph_stage_347"; isCluster="true"; label="Stage 347 (skipped)"; subgraph cluster_2564 { id="cluster_2564"; isCluster="true"; label="LocalTableScan"; 1072 [id="node_1072" labelType="html" label="ParallelCollectionRDD [1072] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1074 [id="node_1074" labelType="html" label="MapPartitionsRDD [1074] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2563 { id="cluster_2563"; isCluster="true"; label="Exchange"; 1076 [id="node_1076" labelType="html" label="MapPartitionsRDD [1076] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 1072->1074; 1074->1076; }

digraph G { id="graph_348"; subgraph graph_stage_348 { id="graph_stage_348"; isCluster="true"; label="Stage 348 (skipped)"; subgraph cluster_2558 { id="cluster_2558"; isCluster="true"; label="LocalTableScan"; 1077 [id="node_1077" labelType="html" label="ParallelCollectionRDD [1077] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1078 [id="node_1078" labelType="html" label="MapPartitionsRDD [1078] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2557 { id="cluster_2557"; isCluster="true"; label="Exchange"; 1079 [id="node_1079" labelType="html" label="MapPartitionsRDD [1079] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 1077->1078; 1078->1079; }

digraph G { id="graph_349"; subgraph graph_stage_349 { id="graph_stage_349"; isCluster="true"; label="Stage 349 (skipped)"; subgraph cluster_2561 { id="cluster_2561"; isCluster="true"; label="LocalTableScan"; 1071 [id="node_1071" labelType="html" label="ParallelCollectionRDD [1071] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1073 [id="node_1073" labelType="html" label="MapPartitionsRDD [1073] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2560 { id="cluster_2560"; isCluster="true"; label="Exchange"; 1075 [id="node_1075" labelType="html" label="MapPartitionsRDD [1075] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 1071->1073; 1073->1075; }

digraph G { id="graph_350"; subgraph graph_stage_350 { id="graph_stage_350"; isCluster="true"; label="Stage 350 (skipped)"; subgraph cluster_2574 { id="cluster_2574"; isCluster="true"; label="AQEShuffleRead"; 1080 [id="node_1080" labelType="html" label="ShuffledRowRDD [1080] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2571 { id="cluster_2571"; isCluster="true"; label="WholeStageCodegen (1)"; 1081 [id="node_1081" labelType="html" label="MapPartitionsRDD [1081] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2579 { id="cluster_2579"; isCluster="true"; label="AQEShuffleRead"; 1082 [id="node_1082" labelType="html" label="ShuffledRowRDD [1082] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2576 { id="cluster_2576"; isCluster="true"; label="WholeStageCodegen (2)"; 1083 [id="node_1083" labelType="html" label="MapPartitionsRDD [1083] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2567 { id="cluster_2567"; isCluster="true"; label="WholeStageCodegen (3)"; 1084 [id="node_1084" labelType="html" label="ZippedPartitionsRDD2 [1084] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1085 [id="node_1085" labelType="html" label="MapPartitionsRDD [1085] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2566 { id="cluster_2566"; isCluster="true"; label="Exchange"; 1086 [id="node_1086" labelType="html" label="MapPartitionsRDD [1086] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 1080->1081; 1082->1083; 1081->1084; 1083->1084; 1084->1085; 1085->1086; }

1079,1080

1075,1082

digraph G { id="graph_351"; subgraph graph_stage_351 { id="graph_stage_351"; isCluster="true"; label="Stage 351"; subgraph cluster_2589 { id="cluster_2589"; isCluster="true"; label="AQEShuffleRead"; 1087 [id="node_1087" labelType="html" label="ShuffledRowRDD [1087] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2586 { id="cluster_2586"; isCluster="true"; label="WholeStageCodegen (4)"; 1088 [id="node_1088" labelType="html" label="MapPartitionsRDD [1088] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2594 { id="cluster_2594"; isCluster="true"; label="AQEShuffleRead"; 1089 [id="node_1089" labelType="html" label="ShuffledRowRDD [1089] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2591 { id="cluster_2591"; isCluster="true"; label="WholeStageCodegen (5)"; 1090 [id="node_1090" labelType="html" label="MapPartitionsRDD [1090] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2581 { id="cluster_2581"; isCluster="true"; label="WholeStageCodegen (6)"; 1091 [id="node_1091" labelType="html" label="ZippedPartitionsRDD2 [1091] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1092 [id="node_1092" labelType="html" label="MapPartitionsRDD [1092] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2580 { id="cluster_2580"; isCluster="true"; label="WriteFiles"; 1093 [id="node_1093" labelType="html" label="MapPartitionsRDD [1093] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 1087->1088; 1089->1090; 1088->1091; 1090->1091; 1091->1092; 1092->1093; }

1086,1087

1076,1089

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
351	tenants-pool-562	replenishmentRunId = 10000001114 tenantId = 4634850980942397731 activityType = PrepareStreams activityId = 88345701-fac2-32a9-a12c-ae48baa9a002 workflowType = CalculateOrderProposalsWorkflow workflowId = a23c6d38-5270-350b-bdd7-e82534bc335a attempt = 1 cornerstoneTenantId = 8476 marketUnit = Grocery_SS 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/07/19 17:56:22	1 s	1/1		29.3 KiB	267.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
350	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
349	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
348	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
347	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

Page: