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

Status: SUCCEEDED
Submitted: 2026/08/31 14:36:39
Duration: 0.4 s
Job Group: 6813b2ad-7812-35f0-8d67-645c7ed180b0
Completed Stages: 2
Skipped Stages: 5

Enable zooming

digraph G { id="graph_341318"; subgraph graph_stage_341318 { id="graph_stage_341318"; isCluster="true"; label="Stage 341318 (skipped)"; 153810 [id="node_153810" labelType="html" label="SQLExecutionRDD [153810] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_381880 { id="cluster_381880"; isCluster="true"; label="map"; 152696 [id="node_152696" labelType="html" label="MapPartitionsRDD [152696] [Cached] [Indeterminate] map at PeriodicAsyncRDDCheckpointWriterImpl.java:207}"]; } subgraph cluster_381881 { id="cluster_381881"; isCluster="true"; label="checkpoint"; 152697 [id="node_152697" labelType="html" label="LocalCheckpointRDD [152697] count at OptimalQuantitiesCacheImpl.java:251}"]; } subgraph cluster_384806 { id="cluster_384806"; isCluster="true"; label="map"; 153799 [id="node_153799" labelType="html" label="MapPartitionsRDD [153799] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384812 { id="cluster_384812"; isCluster="true"; label="WholeStageCodegen (1)"; 153808 [id="node_153808" labelType="html" label="MapPartitionsRDD [153808] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384811 { id="cluster_384811"; isCluster="true"; label="DeserializeToObject"; 153809 [id="node_153809" labelType="html" label="MapPartitionsRDD [153809] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384817 { id="cluster_384817"; isCluster="true"; label="mapPartitions"; 153811 [id="node_153811" labelType="html" label="MapPartitionsRDD [153811] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384818 { id="cluster_384818"; isCluster="true"; label="repartition"; 153812 [id="node_153812" labelType="html" label="MapPartitionsRDD [153812] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 152697->152696; 152696->153799; 153799->153808; 153808->153809; 153809->153810; 153810->153811; 153811->153812; }

152696

153810

152696

153799

153808

153809

153811

153812

digraph G { id="graph_341319"; subgraph graph_stage_341319 { id="graph_stage_341319"; isCluster="true"; label="Stage 341319 (skipped)"; 153883 [id="node_153883" labelType="html" label="SQLExecutionRDD [153883] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_384818 { id="cluster_384818"; isCluster="true"; label="repartition"; 153813 [id="node_153813" labelType="html" label="ShuffledRDD [153813] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153814 [id="node_153814" labelType="html" label="CoalescedRDD [153814] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153815 [id="node_153815" labelType="html" label="MapPartitionsRDD [153815] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384959 { id="cluster_384959"; isCluster="true"; label="map"; 153877 [id="node_153877" labelType="html" label="MapPartitionsRDD [153877] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384970 { id="cluster_384970"; isCluster="true"; label="WholeStageCodegen (1)"; 153881 [id="node_153881" labelType="html" label="MapPartitionsRDD [153881] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384969 { id="cluster_384969"; isCluster="true"; label="DeserializeToObject"; 153882 [id="node_153882" labelType="html" label="MapPartitionsRDD [153882] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384973 { id="cluster_384973"; isCluster="true"; label="mapPartitions"; 153886 [id="node_153886" labelType="html" label="MapPartitionsRDD [153886] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384976 { id="cluster_384976"; isCluster="true"; label="repartition"; 153887 [id="node_153887" labelType="html" label="MapPartitionsRDD [153887] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 153813->153814; 153814->153815; 153815->153877; 153877->153881; 153881->153882; 153882->153883; 153883->153886; 153886->153887; }

153812,153813

153815

153883

153813

153814

153815

153877

153881

153882

153886

153887

digraph G { id="graph_341320"; subgraph graph_stage_341320 { id="graph_stage_341320"; isCluster="true"; label="Stage 341320 (skipped)"; subgraph cluster_386081 { id="cluster_386081"; isCluster="true"; label="Scan parquet "; 154391 [id="node_154391" labelType="html" label="FileScanRDD [154391] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154392 [id="node_154392" labelType="html" label="MapPartitionsRDD [154392] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386076 { id="cluster_386076"; isCluster="true"; label="WholeStageCodegen (1)"; 154393 [id="node_154393" labelType="html" label="MapPartitionsRDD [154393] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386075 { id="cluster_386075"; isCluster="true"; label="Exchange"; 154394 [id="node_154394" labelType="html" label="MapPartitionsRDD [154394] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 154391->154392; 154392->154393; 154393->154394; }

digraph G { id="graph_341321"; subgraph graph_stage_341321 { id="graph_stage_341321"; isCluster="true"; label="Stage 341321 (skipped)"; subgraph cluster_386086 { id="cluster_386086"; isCluster="true"; label="Exchange"; 154395 [id="node_154395" labelType="html" label="ShuffledRowRDD [154395] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386082 { id="cluster_386082"; isCluster="true"; label="WholeStageCodegen (2)"; 154396 [id="node_154396" labelType="html" label="MapPartitionsRDD [154396] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386087 { id="cluster_386087"; isCluster="true"; label="mapPartitionsInternal"; 154397 [id="node_154397" labelType="html" label="MapPartitionsRDD [154397] [Unordered] isEmpty at OrderQuantityOptimizationImpl.java:151}"]; } subgraph cluster_386088 { id="cluster_386088"; isCluster="true"; label="mapPartitionsInternal"; 154398 [id="node_154398" labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [0_5_10000000532 AS shardId#3617984, worklistShardItemId#3618052L, orderProposalId#3618029L, orderProposalItemId#3618030, orderProposalItemGroupId#3618053, originalReplenishmentRunId#3618071L, orderProposalHorizonGroupingId#3618047L, splitIndicator#3618048L, previousOrderProposal#3618049L, clusterId#3618050L, cast(sequenceId#3618051 as bigint) AS sequenceId#3617994L, sourceOfSupplyUuid#3618043, supplierGroup#3618031, supplier#3618032, subrange#3618035, product#3618038, plant#3618033, purchasingOrg#3618044, purchasingGroup#3618045, mrpController#3618042, orderDateTime#3618039, deliveryDateTime#3618034, availabilityDateTime#3618040, nextAvailabilityDateTime#3618041, isFallbackOrderOnly#3618046, ... 20 more fields]\n +- Exchange hashpartitioning(worklistShardItemId#3618052L, 37), REPARTITION_BY_NUM, [plan_id=1036246]\n +- Project [orderProposalId#3618029L, orderProposalItemId#3618030, supplierGroup#3618031, supplier#3618032, plant#3618033, deliveryDateTime#3... [154398] [Cached] [Unordered] isEmpty at OrderQuantityOptimizationImpl.java:151}"]; } subgraph cluster_386176 { id="cluster_386176"; isCluster="true"; label="InMemoryTableScan"; 154433 [id="node_154433" labelType="html" label="MapPartitionsRDD [154433] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154434 [id="node_154434" labelType="html" label="MapPartitionsRDD [154434] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154435 [id="node_154435" labelType="html" label="MapPartitionsRDD [154435] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386166 { id="cluster_386166"; isCluster="true"; label="WholeStageCodegen (1)"; 154436 [id="node_154436" labelType="html" label="MapPartitionsRDD [154436] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386165 { id="cluster_386165"; isCluster="true"; label="ObjectHashAggregate"; 154437 [id="node_154437" labelType="html" label="MapPartitionsRDD [154437] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386164 { id="cluster_386164"; isCluster="true"; label="Exchange"; 154438 [id="node_154438" labelType="html" label="MapPartitionsRDD [154438] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 154395->154396; 154396->154397; 154397->154398; 154398->154433; 154433->154434; 154434->154435; 154435->154436; 154436->154437; 154437->154438; }

154394,154395

154398

digraph G { id="graph_341322"; subgraph graph_stage_341322 { id="graph_stage_341322"; isCluster="true"; label="Stage 341322 (skipped)"; 153992 [id="node_153992" labelType="html" label="SQLExecutionRDD [153992] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_384976 { id="cluster_384976"; isCluster="true"; label="repartition"; 153888 [id="node_153888" labelType="html" label="ShuffledRDD [153888] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153889 [id="node_153889" labelType="html" label="CoalescedRDD [153889] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153890 [id="node_153890" labelType="html" label="MapPartitionsRDD [153890] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385221 { id="cluster_385221"; isCluster="true"; label="map"; 153989 [id="node_153989" labelType="html" label="MapPartitionsRDD [153989] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385223 { id="cluster_385223"; isCluster="true"; label="WholeStageCodegen (1)"; 153990 [id="node_153990" labelType="html" label="MapPartitionsRDD [153990] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385222 { id="cluster_385222"; isCluster="true"; label="DeserializeToObject"; 153991 [id="node_153991" labelType="html" label="MapPartitionsRDD [153991] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385226 { id="cluster_385226"; isCluster="true"; label="mapPartitions"; 153993 [id="node_153993" labelType="html" label="MapPartitionsRDD [153993] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385227 { id="cluster_385227"; isCluster="true"; label="repartition"; 153994 [id="node_153994" labelType="html" label="MapPartitionsRDD [153994] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 153888->153889; 153889->153890; 153890->153989; 153989->153990; 153990->153991; 153991->153992; 153992->153993; 153993->153994; }

153887,153888

153890

153992

153888

153889

153890

153989

153990

153991

153993

153994

digraph G { id="graph_341323"; subgraph graph_stage_341323 { id="graph_stage_341323"; isCluster="true"; label="Stage 341323"; 154459 [id="node_154459" labelType="html" label="SQLExecutionRDD [154459] [Indeterminate] javaRDD at OptimalQuantitiesCacheImpl.java:177}"]; subgraph cluster_385227 { id="cluster_385227"; isCluster="true"; label="repartition"; 153995 [id="node_153995" labelType="html" label="ShuffledRDD [153995] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153996 [id="node_153996" labelType="html" label="CoalescedRDD [153996] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153997 [id="node_153997" labelType="html" label="MapPartitionsRDD [153997] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_386161 { id="cluster_386161"; isCluster="true"; label="map"; 154432 [id="node_154432" labelType="html" label="MapPartitionsRDD [154432] [Indeterminate] createDataFrame at OptimalQuantitiesCacheImpl.java:212}"]; } subgraph cluster_386226 { id="cluster_386226"; isCluster="true"; label="WholeStageCodegen (7)"; 154453 [id="node_154453" labelType="html" label="MapPartitionsRDD [154453] [Indeterminate] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386230 { id="cluster_386230"; isCluster="true"; label="AQEShuffleRead"; 154454 [id="node_154454" labelType="html" label="ShuffledRowRDD [154454] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386229 { id="cluster_386229"; isCluster="true"; label="ObjectHashAggregate"; 154455 [id="node_154455" labelType="html" label="MapPartitionsRDD [154455] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386225 { id="cluster_386225"; isCluster="true"; label="Union"; 154456 [id="node_154456" labelType="html" label="UnionRDD [154456] [Indeterminate] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386218 { id="cluster_386218"; isCluster="true"; label="WholeStageCodegen (8)"; 154457 [id="node_154457" labelType="html" label="MapPartitionsRDD [154457] [Indeterminate] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386217 { id="cluster_386217"; isCluster="true"; label="DeserializeToObject"; 154458 [id="node_154458" labelType="html" label="MapPartitionsRDD [154458] [Indeterminate] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386231 { id="cluster_386231"; isCluster="true"; label="mapPartitions"; 154460 [id="node_154460" labelType="html" label="MapPartitionsRDD [154460] [Indeterminate] javaRDD at OptimalQuantitiesCacheImpl.java:177}"]; } subgraph cluster_386232 { id="cluster_386232"; isCluster="true"; label="repartition"; 154461 [id="node_154461" labelType="html" label="MapPartitionsRDD [154461] [Indeterminate] repartition at OptimalQuantitiesCacheImpl.java:178}"]; } } 153995->153996; 153996->153997; 153997->154432; 154432->154453; 154454->154455; 154453->154456; 154455->154456; 154456->154457; 154457->154458; 154458->154459; 154459->154460; 154460->154461; }

153994,153995

154438,154454

153997

154459

153995

153996

153997

154432

154453

154456

154457

154458

154460

154461

digraph G { id="graph_341324"; subgraph graph_stage_341324 { id="graph_stage_341324"; isCluster="true"; label="Stage 341324"; subgraph cluster_386232 { id="cluster_386232"; isCluster="true"; label="repartition"; 154462 [id="node_154462" labelType="html" label="ShuffledRDD [154462] [Indeterminate] repartition at OptimalQuantitiesCacheImpl.java:178}"]; 154463 [id="node_154463" labelType="html" label="CoalescedRDD [154463] [Indeterminate] repartition at OptimalQuantitiesCacheImpl.java:178}"]; 154464 [id="node_154464" labelType="html" label="MapPartitionsRDD [154464] [Cached] [Indeterminate] repartition at OptimalQuantitiesCacheImpl.java:178}"]; } } 154462->154463; 154463->154464; }

154461,154462

154464

154462

154463

154464

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
341324	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 count at OptimalQuantitiesCacheImpl.java:243 +details org.apache.spark.api.java.AbstractJavaRDDLike.count(JavaRDDLike.scala:46) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.logRDDCountInfo(OptimalQuantitiesCacheImpl.java:243) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.addToCache(OptimalQuantitiesCacheImpl.java:181) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.initializeWithWorklist(OptimalQuantitiesCacheImpl.java:71) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:159) 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:40	80 ms	37/37			1530.1 KiB
341323	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 repartition at OptimalQuantitiesCacheImpl.java:178 +details org.apache.spark.api.java.JavaRDD.repartition(JavaRDD.scala:118) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.addToCache(OptimalQuantitiesCacheImpl.java:178) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.initializeWithWorklist(OptimalQuantitiesCacheImpl.java:71) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:159) 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:39	0.3 s	66/66	630.0 B		2.2 MiB	1530.1 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

341324

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 count at OptimalQuantitiesCacheImpl.java:243 +details

org.apache.spark.api.java.AbstractJavaRDDLike.count(JavaRDDLike.scala:46)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.logRDDCountInfo(OptimalQuantitiesCacheImpl.java:243)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.addToCache(OptimalQuantitiesCacheImpl.java:181)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.initializeWithWorklist(OptimalQuantitiesCacheImpl.java:71)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:159)
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:40

80 ms

37/37

1530.1 KiB

341323

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 repartition at OptimalQuantitiesCacheImpl.java:178 +details

org.apache.spark.api.java.JavaRDD.repartition(JavaRDD.scala:118)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.addToCache(OptimalQuantitiesCacheImpl.java:178)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.OptimalQuantitiesCacheImpl.initializeWithWorklist(OptimalQuantitiesCacheImpl.java:71)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:159)
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:39

0.3 s

66/66

630.0 B

2.2 MiB

1530.1 KiB

Page:

Skipped Stages (5)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
341322	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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)	Unknown	Unknown	0/30
341321	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
341320	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
341319	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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)	Unknown	Unknown	0/30
341318	default	start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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)	Unknown	Unknown	0/30

Page: