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

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

Enable zooming

digraph G { id="graph_341299"; subgraph graph_stage_341299 { id="graph_stage_341299"; isCluster="true"; label="Stage 341299 (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_341300"; subgraph graph_stage_341300 { id="graph_stage_341300"; isCluster="true"; label="Stage 341300"; 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_386142 { id="cluster_386142"; isCluster="true"; label="InMemoryTableScan"; 154421 [id="node_154421" labelType="html" label="MapPartitionsRDD [154421] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154422 [id="node_154422" labelType="html" label="MapPartitionsRDD [154422] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154423 [id="node_154423" labelType="html" label="MapPartitionsRDD [154423] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386140 { id="cluster_386140"; isCluster="true"; label="CollectLimit"; 154424 [id="node_154424" labelType="html" label="MapPartitionsRDD [154424] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154425 [id="node_154425" labelType="html" label="MapPartitionsRDD [154425] [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->154421; 154421->154422; 154422->154423; 154423->154424; 154424->154425; }

148708,148709

148734

digraph G { id="graph_341301"; subgraph graph_stage_341301 { id="graph_stage_341301"; isCluster="true"; label="Stage 341301"; subgraph cluster_386140 { id="cluster_386140"; isCluster="true"; label="CollectLimit"; 154426 [id="node_154426" labelType="html" label="ShuffledRowRDD [154426] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154427 [id="node_154427" labelType="html" label="MapPartitionsRDD [154427] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386143 { id="cluster_386143"; isCluster="true"; label="mapPartitionsInternal"; 154428 [id="node_154428" labelType="html" label="MapPartitionsRDD [154428] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 154426->154427; 154427->154428; }

154425,154426

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
341301	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:36	13 ms	1/1
341300	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:36	25 ms	37/37	4.9 MiB			2.2 KiB

Page:

Skipped Stages (1)

Page:

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

341299

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: