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

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

Enable zooming

digraph G { id="graph_341292"; subgraph graph_stage_341292 { id="graph_stage_341292"; isCluster="true"; label="Stage 341292 (skipped)"; subgraph cluster_372054 { id="cluster_372054"; isCluster="true"; label="Scan parquet "; 148705 [id="node_148705" labelType="html" label="FileScanRDD [148705] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 148706 [id="node_148706" labelType="html" label="MapPartitionsRDD [148706] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_372049 { id="cluster_372049"; isCluster="true"; label="WholeStageCodegen (1)"; 148707 [id="node_148707" labelType="html" label="MapPartitionsRDD [148707] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_372048 { id="cluster_372048"; isCluster="true"; label="Exchange"; 148708 [id="node_148708" labelType="html" label="MapPartitionsRDD [148708] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 148705->148706; 148706->148707; 148707->148708; }

digraph G { id="graph_341293"; subgraph graph_stage_341293 { id="graph_stage_341293"; isCluster="true"; label="Stage 341293"; subgraph cluster_372059 { id="cluster_372059"; isCluster="true"; label="Exchange"; 148709 [id="node_148709" labelType="html" label="ShuffledRowRDD [148709] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_372055 { id="cluster_372055"; isCluster="true"; label="WholeStageCodegen (2)"; 148710 [id="node_148710" labelType="html" label="MapPartitionsRDD [148710] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_372060 { id="cluster_372060"; isCluster="true"; label="mapPartitionsInternal"; 148711 [id="node_148711" labelType="html" label="MapPartitionsRDD [148711] [Unordered] isEmpty at OrderQuantityOptimizationImpl.java:151}"]; } subgraph cluster_372061 { id="cluster_372061"; isCluster="true"; label="mapPartitionsInternal"; 148712 [id="node_148712" labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [0_5_10000000532 AS shardId#3494814, worklistShardItemId#3494882L, orderProposalId#3494859L, orderProposalItemId#3494860, orderProposalItemGroupId#3494883, originalReplenishmentRunId#3494901L, orderProposalHorizonGroupingId#3494877L, splitIndicator#3494878L, previousOrderProposal#3494879L, clusterId#3494880L, cast(sequenceId#3494881 as bigint) AS sequenceId#3494824L, sourceOfSupplyUuid#3494873, supplierGroup#3494861, supplier#3494862, subrange#3494865, product#3494868, plant#3494863, purchasingOrg#3494874, purchasingGroup#3494875, mrpController#3494872, orderDateTime#3494869, deliveryDateTime#3494864, availabilityDateTime#3494870, nextAvailabilityDateTime#3494871, isFallbackOrderOnly#3494876, ... 20 more fields]\n +- Exchange hashpartitioning(worklistShardItemId#3494882L, 37), REPARTITION_BY_NUM, [plan_id=1002954]\n +- Project [orderProposalId#3494859L, orderProposalItemId#3494860, supplierGroup#3494861, supplier#3494862, plant#3494863, deliveryDateTime#3... [148712] [Unordered] isEmpty at OrderQuantityOptimizationImpl.java:151}"]; } subgraph cluster_372109 { id="cluster_372109"; isCluster="true"; label="InMemoryTableScan"; 148729 [id="node_148729" labelType="html" label="MapPartitionsRDD [148729] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 148730 [id="node_148730" labelType="html" label="MapPartitionsRDD [148730] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 148731 [id="node_148731" labelType="html" label="MapPartitionsRDD [148731] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_372105 { id="cluster_372105"; isCluster="true"; label="WholeStageCodegen (1)"; 148732 [id="node_148732" labelType="html" label="MapPartitionsRDD [148732] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_372110 { id="cluster_372110"; isCluster="true"; label="mapPartitionsInternal"; 148733 [id="node_148733" labelType="html" label="MapPartitionsRDD [148733] [Unordered] isEmpty at FileStorageAdapterImpl.java:601}"]; } subgraph cluster_372111 { id="cluster_372111"; isCluster="true"; label="mapPartitionsInternal"; 148734 [id="node_148734" labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [shardId#3494814, worklistShardItemId#3494815L, product#3494829, plant#3494830, availabilityDateTime#3494836 AS periodStart#3497073, nextAvailabilityDateTime#3494837 AS periodEnd#3497074, 0 AS version#3497072, null AS qty#3497075]\n +- InMemoryTableScan [availabilityDateTime#3494836, nextAvailabilityDateTime#3494837, plant#3494830, product#3494829, shardId#3494814, worklistShardItemId#3494815L]\n +- InMemoryRelation [shardId#3494814, worklistShardItemId#3494815L, orderProposalId#3494816L, orderProposalItemId#3494817, orderProposalItemGroupId#3494818, originalReplenishmentRunId#3494819L, orderProposalHorizonGroupingId#3494820L, splitIndicator#3494821L, previousOrderProposal#3494822L, clusterId#3494823L, sequenceId#3494824L, sourceOfSupplyUuid#3494825, supplierGroup#3494826, supplier#3494827, subrange#3494828, product#3494829, plant#3494830, purchasingOrg#3494831, purchasingGroup#3494832, mrpController#3494833, orderDateTime#3494834, deliveryDateTime#349... [148734] [Cached] [Unordered] isEmpty at FileStorageAdapterImpl.java:601}"]; } subgraph cluster_386115 { id="cluster_386115"; isCluster="true"; label="InMemoryTableScan"; 154407 [id="node_154407" labelType="html" label="MapPartitionsRDD [154407] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154408 [id="node_154408" labelType="html" label="MapPartitionsRDD [154408] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154409 [id="node_154409" labelType="html" label="MapPartitionsRDD [154409] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386111 { id="cluster_386111"; isCluster="true"; label="WholeStageCodegen (1)"; 154410 [id="node_154410" labelType="html" label="MapPartitionsRDD [154410] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386110 { id="cluster_386110"; isCluster="true"; label="Exchange"; 154411 [id="node_154411" labelType="html" label="MapPartitionsRDD [154411] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 148709->148710; 148710->148711; 148711->148712; 148712->148729; 148729->148730; 148730->148731; 148731->148732; 148732->148733; 148733->148734; 148734->154407; 154407->154408; 154408->154409; 154409->154410; 154410->154411; }

148708,148709

148734

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
341293	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 RDD: AdaptiveSparkPlan isFinalPlan=false +- Project [shardId#3494814, worklistShardItemId#3494815L, product#3494829, plant#3494830, availabilityDateTime#3494836 AS periodStart#3497073, nextAvailabilityDateTime#3494837 AS periodEnd#3497074, 0 AS version#3497072, null AS qty#3497075] +- InMemoryTableScan [availabilityDateTime#3494836, nextAvailabilityDateTime#3494837, plant#3494830, product#3494829, shardId#3494814, worklistShardItemId#3494815L] +- InMemoryRelation [shardId#3494814, worklistShardItemId#3494815L, orderProposalId#3494816L, orderProposalItemId#3494817, orderProposalItemGroupId#3494818, originalReplenishmentRunId#3494819L, orderProposalHorizonGroupingId#3494820L, splitIndicator#3494821L, previousOrderProposal#3494822L, clusterId#3494823L, sequenceId#3494824L, sourceOfSupplyUuid#3494825, supplierGroup#3494826, supplier#3494827, subrange#3494828, product#3494829, plant#3494830, purchasingOrg#3494831, purchasingGroup#3494832, mrpController#3494833, orderDateTime#3494834, deliveryDateTime#349... 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:35	0.5 s	37/37	4.9 MiB			3.3 KiB

Page:

Skipped Stages (1)

Page:

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

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

341292

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/37

Page: