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

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

Enable zooming

digraph G { id="graph_341304"; subgraph graph_stage_341304 { id="graph_stage_341304"; isCluster="true"; label="Stage 341304 (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_341307"; subgraph graph_stage_341307 { id="graph_stage_341307"; isCluster="true"; label="Stage 341307 (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_341308"; subgraph graph_stage_341308 { id="graph_stage_341308"; isCluster="true"; label="Stage 341308 (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_341309"; subgraph graph_stage_341309 { id="graph_stage_341309"; isCluster="true"; label="Stage 341309 (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_386178 { id="cluster_386178"; isCluster="true"; label="InMemoryTableScan"; 154439 [id="node_154439" labelType="html" label="MapPartitionsRDD [154439] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154440 [id="node_154440" labelType="html" label="MapPartitionsRDD [154440] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154441 [id="node_154441" labelType="html" label="MapPartitionsRDD [154441] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386171 { id="cluster_386171"; isCluster="true"; label="WholeStageCodegen (2)"; 154442 [id="node_154442" labelType="html" label="MapPartitionsRDD [154442] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386170 { id="cluster_386170"; isCluster="true"; label="Exchange"; 154443 [id="node_154443" labelType="html" label="MapPartitionsRDD [154443] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 154395->154396; 154396->154397; 154397->154398; 154398->154439; 154439->154440; 154440->154441; 154441->154442; 154442->154443; }

154394,154395

154398

digraph G { id="graph_341310"; subgraph graph_stage_341310 { id="graph_stage_341310"; isCluster="true"; label="Stage 341310 (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_341311"; subgraph graph_stage_341311 { id="graph_stage_341311"; isCluster="true"; label="Stage 341311"; 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_386185 { id="cluster_386185"; isCluster="true"; label="WholeStageCodegen (3)"; 154444 [id="node_154444" labelType="html" label="MapPartitionsRDD [154444] [Indeterminate] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386192 { id="cluster_386192"; isCluster="true"; label="AQEShuffleRead"; 154445 [id="node_154445" labelType="html" label="ShuffledRowRDD [154445] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386189 { id="cluster_386189"; isCluster="true"; label="WholeStageCodegen (4)"; 154446 [id="node_154446" labelType="html" label="MapPartitionsRDD [154446] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386184 { id="cluster_386184"; isCluster="true"; label="Union"; 154447 [id="node_154447" labelType="html" label="UnionRDD [154447] [Indeterminate] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386181 { id="cluster_386181"; isCluster="true"; label="WholeStageCodegen (5)"; 154448 [id="node_154448" labelType="html" label="MapPartitionsRDD [154448] [Indeterminate] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386180 { id="cluster_386180"; isCluster="true"; label="Exchange"; 154449 [id="node_154449" labelType="html" label="MapPartitionsRDD [154449] [Indeterminate] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 153995->153996; 153996->153997; 153997->154432; 154432->154444; 154445->154446; 154444->154447; 154446->154447; 154447->154448; 154448->154449; }

153994,153995

154443,154445

153997

153995

153996

153997

154432

154444

154447

154448

154449

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
341311	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:39	0.2 s	45/45	630.0 B		887.2 KiB	31.1 KiB

Page:

Skipped Stages (5)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
341310	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
341309	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
341308	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
341307	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
341304	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

Page: