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

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

Enable zooming

digraph G { id="graph_344"; subgraph graph_stage_344 { id="graph_stage_344"; isCluster="true"; label="Stage 344 (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_345"; subgraph graph_stage_345 { id="graph_stage_345"; isCluster="true"; label="Stage 345 (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_346"; subgraph graph_stage_346 { id="graph_stage_346"; isCluster="true"; label="Stage 346"; 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

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
346	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	0.2 s	1/1			263.0 B	170.0 B

Page:

Skipped Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
345	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
344	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

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

345

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

0/1

344

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

0/1

Page: