crp-order-quantity-kpi-service

Status: SUCCEEDED
Submitted: 2026/02/06 06:55:10
Duration: 0.6 s
Associated SQL Query: 5
Job Group: f7c8bcdf-0636-3283-a6d4-2f6723afc071
Completed Stages: 1
Skipped Stages: 2

Enable zooming

digraph G { id="graph_4"; subgraph graph_stage_4 { id="graph_stage_4"; isCluster="true"; label="Stage 4 (skipped)"; subgraph cluster_31 { id="cluster_31"; isCluster="true"; label="LocalTableScan"; 22 [id="node_22" labelType="html" label="ParallelCollectionRDD [22] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 23 [id="node_23" labelType="html" label="MapPartitionsRDD [23] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_30 { id="cluster_30"; isCluster="true"; label="Exchange"; 24 [id="node_24" labelType="html" label="MapPartitionsRDD [24] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 22->23; 23->24; }

digraph G { id="graph_5"; subgraph graph_stage_5 { id="graph_stage_5"; isCluster="true"; label="Stage 5 (skipped)"; subgraph cluster_34 { id="cluster_34"; isCluster="true"; label="LocalTableScan"; 17 [id="node_17" labelType="html" label="ParallelCollectionRDD [17] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 18 [id="node_18" labelType="html" label="MapPartitionsRDD [18] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_33 { id="cluster_33"; isCluster="true"; label="Exchange"; 20 [id="node_20" labelType="html" label="MapPartitionsRDD [20] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 17->18; 18->20; }

digraph G { id="graph_6"; subgraph graph_stage_6 { id="graph_stage_6"; isCluster="true"; label="Stage 6"; subgraph cluster_47 { id="cluster_47"; isCluster="true"; label="AQEShuffleRead"; 25 [id="node_25" labelType="html" label="ShuffledRowRDD [25] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_44 { id="cluster_44"; isCluster="true"; label="WholeStageCodegen (1)"; 26 [id="node_26" labelType="html" label="MapPartitionsRDD [26] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_52 { id="cluster_52"; isCluster="true"; label="AQEShuffleRead"; 27 [id="node_27" labelType="html" label="ShuffledRowRDD [27] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_49 { id="cluster_49"; isCluster="true"; label="WholeStageCodegen (2)"; 28 [id="node_28" labelType="html" label="MapPartitionsRDD [28] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_40 { id="cluster_40"; isCluster="true"; label="WholeStageCodegen (3)"; 29 [id="node_29" labelType="html" label="ZippedPartitionsRDD2 [29] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 30 [id="node_30" labelType="html" label="MapPartitionsRDD [30] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_39 { id="cluster_39"; isCluster="true"; label="Exchange"; 31 [id="node_31" labelType="html" label="MapPartitionsRDD [31] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 25->26; 27->28; 26->29; 28->29; 29->30; 30->31; }

24,25

20,27

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
6	tenants-pool-286	replenishmentRunId = 10000000095 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = f7c8bcdf-0636-3283-a6d4-2f6723afc071 workflowType = CalculateOrderProposalsWorkflow workflowId = eba25ea7-bf45-3f36-ad32-cdab1a2c01e5 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery 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/02/06 06:55:10	0.6 s	1/1			284.0 B	195.0 B

Page:

Skipped Stages (2)

Page:

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

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

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:

Details for Job 6

Completed Stages (1)

Skipped Stages (2)