crp-order-qty-opt-service - Details for Job 18770

Status: SUCCEEDED
Submitted: 2026/08/31 14:36:40
Duration: 0.7 s
Associated SQL Query: 13550
Job Group: 6813b2ad-7812-35f0-8d67-645c7ed180b0
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_341331"; subgraph graph_stage_341331 { id="graph_stage_341331"; isCluster="true"; label="Stage 341331 (skipped)"; subgraph cluster_386261 { id="cluster_386261"; isCluster="true"; label="LocalTableScan"; 154466 [id="node_154466" labelType="html" label="ParallelCollectionRDD [154466] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154469 [id="node_154469" labelType="html" label="MapPartitionsRDD [154469] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386260 { id="cluster_386260"; isCluster="true"; label="Exchange"; 154470 [id="node_154470" labelType="html" label="MapPartitionsRDD [154470] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 154466->154469; 154469->154470; }

digraph G { id="graph_341332"; subgraph graph_stage_341332 { id="graph_stage_341332"; isCluster="true"; label="Stage 341332 (skipped)"; subgraph cluster_386255 { id="cluster_386255"; isCluster="true"; label="LocalTableScan"; 154471 [id="node_154471" labelType="html" label="ParallelCollectionRDD [154471] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154472 [id="node_154472" labelType="html" label="MapPartitionsRDD [154472] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386254 { id="cluster_386254"; isCluster="true"; label="Exchange"; 154473 [id="node_154473" labelType="html" label="MapPartitionsRDD [154473] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 154471->154472; 154472->154473; }

digraph G { id="graph_341333"; subgraph graph_stage_341333 { id="graph_stage_341333"; isCluster="true"; label="Stage 341333 (skipped)"; subgraph cluster_386258 { id="cluster_386258"; isCluster="true"; label="LocalTableScan"; 154465 [id="node_154465" labelType="html" label="ParallelCollectionRDD [154465] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154467 [id="node_154467" labelType="html" label="MapPartitionsRDD [154467] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386257 { id="cluster_386257"; isCluster="true"; label="Exchange"; 154468 [id="node_154468" labelType="html" label="MapPartitionsRDD [154468] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 154465->154467; 154467->154468; }

digraph G { id="graph_341334"; subgraph graph_stage_341334 { id="graph_stage_341334"; isCluster="true"; label="Stage 341334 (skipped)"; subgraph cluster_386271 { id="cluster_386271"; isCluster="true"; label="AQEShuffleRead"; 154474 [id="node_154474" labelType="html" label="ShuffledRowRDD [154474] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386268 { id="cluster_386268"; isCluster="true"; label="WholeStageCodegen (1)"; 154475 [id="node_154475" labelType="html" label="MapPartitionsRDD [154475] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386276 { id="cluster_386276"; isCluster="true"; label="AQEShuffleRead"; 154476 [id="node_154476" labelType="html" label="ShuffledRowRDD [154476] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386273 { id="cluster_386273"; isCluster="true"; label="WholeStageCodegen (2)"; 154477 [id="node_154477" labelType="html" label="MapPartitionsRDD [154477] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386264 { id="cluster_386264"; isCluster="true"; label="WholeStageCodegen (3)"; 154478 [id="node_154478" labelType="html" label="ZippedPartitionsRDD2 [154478] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154479 [id="node_154479" labelType="html" label="MapPartitionsRDD [154479] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386263 { id="cluster_386263"; isCluster="true"; label="Exchange"; 154480 [id="node_154480" labelType="html" label="MapPartitionsRDD [154480] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 154474->154475; 154476->154477; 154475->154478; 154477->154478; 154478->154479; 154479->154480; }

154473,154474

154468,154476

digraph G { id="graph_341335"; subgraph graph_stage_341335 { id="graph_stage_341335"; isCluster="true"; label="Stage 341335"; subgraph cluster_386286 { id="cluster_386286"; isCluster="true"; label="AQEShuffleRead"; 154481 [id="node_154481" labelType="html" label="ShuffledRowRDD [154481] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386283 { id="cluster_386283"; isCluster="true"; label="WholeStageCodegen (4)"; 154482 [id="node_154482" labelType="html" label="MapPartitionsRDD [154482] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386291 { id="cluster_386291"; isCluster="true"; label="AQEShuffleRead"; 154483 [id="node_154483" labelType="html" label="ShuffledRowRDD [154483] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386288 { id="cluster_386288"; isCluster="true"; label="WholeStageCodegen (5)"; 154484 [id="node_154484" labelType="html" label="MapPartitionsRDD [154484] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386278 { id="cluster_386278"; isCluster="true"; label="WholeStageCodegen (6)"; 154485 [id="node_154485" labelType="html" label="ZippedPartitionsRDD2 [154485] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154486 [id="node_154486" labelType="html" label="MapPartitionsRDD [154486] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386277 { id="cluster_386277"; isCluster="true"; label="WriteFiles"; 154487 [id="node_154487" labelType="html" label="MapPartitionsRDD [154487] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 154481->154482; 154483->154484; 154482->154485; 154484->154485; 154485->154486; 154486->154487; }

154480,154481

154470,154483

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
341335	tenants-pool-506	replenishmentRunId = 10000000532 tenantId = 8793759653749352888 activityType = TriggerOptimize activityId = 6813b2ad-7812-35f0-8d67-645c7ed180b0 workflowType = CalculateOrderProposalsForShardWorkflow workflowId = 7d5b0d3e-a8b4-3f66-a348-065089418e78 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/08/31 14:36:40	0.7 s	1/1		35.7 KiB	7.0 KiB

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
341334	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
341333	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/20
341332	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/20
341331	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/20

Page: