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

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

Enable zooming

digraph G { id="graph_341302"; subgraph graph_stage_341302 { id="graph_stage_341302"; isCluster="true"; label="Stage 341302 (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_341303"; subgraph graph_stage_341303 { id="graph_stage_341303"; isCluster="true"; label="Stage 341303"; 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_386156 { id="cluster_386156"; isCluster="true"; label="InMemoryTableScan"; 154429 [id="node_154429" labelType="html" label="MapPartitionsRDD [154429] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154430 [id="node_154430" labelType="html" label="MapPartitionsRDD [154430] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154431 [id="node_154431" labelType="html" label="MapPartitionsRDD [154431] [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->154429; 154429->154430; 154430->154431; }

148708,148709

148734

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
341303	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 save at FileStorageAdapterImpl.java:623 +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.classic.DataFrameWriter.save(DataFrameWriter.scala:118) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:623) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:201) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:157) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:49) jdk.internal.reflect.GeneratedMethodAccessor620.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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:37	0.7 s	37/37	4.9 MiB	4.5 MiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

341303

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 save at FileStorageAdapterImpl.java:623 +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.classic.DataFrameWriter.save(DataFrameWriter.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeOrderProposalUpdateForStreaming(FileStorageAdapterImpl.java:623)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.StoragePortProxyImpl.storeOrderProposalUpdate(StoragePortProxyImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.storeInitialOrderProposalUpdate(OrderQuantityOptimizationImpl.java:201)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:157)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:49)
jdk.internal.reflect.GeneratedMethodAccessor620.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23)
io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88)
io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
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:37

0.7 s

37/37

4.9 MiB

4.5 MiB

Page:

Skipped Stages (1)

Page:

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

341302

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: