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

Status: SUCCEEDED
Submitted: 2026/02/06 06:54:51
Duration: 19 ms
Associated SQL Query: 21
Job Group: 26269996-b72a-3f7e-9814-66d8981041bd
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { subgraph clusterstage_72 { label="Stage 72 (skipped)"; subgraph cluster468 { label="Scan parquet "; 164 [labelType="html" label="FileScanRDD [164] count at WorklistShardingImpl.java:107"]; 165 [labelType="html" label="MapPartitionsRDD [165] count at WorklistShardingImpl.java:107"]; } subgraph cluster464 { label="WholeStageCodegen (1)"; 166 [labelType="html" label="MapPartitionsRDD [166] count at WorklistShardingImpl.java:107"]; } subgraph cluster463 { label="Exchange"; 167 [labelType="html" label="MapPartitionsRDD [167] count at WorklistShardingImpl.java:107"]; 168 [labelType="html" label="MapPartitionsRDD [168] count at WorklistShardingImpl.java:107"]; } } 164->165; 165->166; 166->167; 167->168; }

digraph G { subgraph clusterstage_73 { label="Stage 73 (skipped)"; subgraph cluster485 { label="Exchange"; 181 [labelType="html" label="ShuffledRowRDD [181] [Unordered] count at WorklistShardingImpl.java:107"]; } subgraph cluster483 { label="Exchange"; 182 [labelType="html" label="MapPartitionsRDD [182] [Unordered] count at WorklistShardingImpl.java:107"]; } } 181->182; }

168,181

digraph G { subgraph clusterstage_74 { label="Stage 74 (skipped)"; subgraph cluster526 { label="Exchange"; 188 [labelType="html" label="ShuffledRowRDD [188] [Unordered] count at WorklistShardingImpl.java:107"]; } subgraph cluster516 { label="WholeStageCodegen (5)"; 189 [labelType="html" label="MapPartitionsRDD [189] [Unordered] count at WorklistShardingImpl.java:107"]; } subgraph cluster527 { label="mapPartitionsInternal"; 190 [labelType="html" label="MapPartitionsRDD [190] [Unordered] count at WorklistShardingImpl.java:107"]; } subgraph cluster528 { label="mapPartitionsInternal"; 191 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderScheduleExploded#3301.product AS product#3315, productOrderScheduleExploded#3301.orderDateTime AS orderDateTime#3316, productOrderScheduleExploded#3301.availabilityDateTime AS availabilityDateTime#3317, productOrderScheduleExploded#3301.nextAvailabilityDateTime AS nextAvailabilityDateTime#3318, productOrderScheduleExploded#3301.mrpController AS mrpController#3319, productOrderScheduleExploded#3301.sourceOfSupplyUuid AS sourceOfSupplyUuid#3320, productOrderScheduleExploded#3301.purchasingOrg AS purchasingOrg#3321, productOrderScheduleExploded#3301.purchasingGroup AS purchasingGroup#3322, xxhash64(CASE WHEN (_extract_supplier#4175 <=> true) THEN supplierOrGroup#3208 END, CASE WHEN (_extract_deliveryDate#4176 <=> true) THEN deliveryDateTime#3002 END, CASE WHEN (_extract_orderDate#4177 <=> true) THEN productOrderScheduleExploded#3301.orderDateTime END, CASE WHEN (_ext... [191] [Cached] [Unordered] count at WorklistShardingImpl.java:107"]; } subgraph cluster566 { label="InMemoryTableScan"; 200 [labelType="html" label="MapPartitionsRDD [200] [Unordered] count at WorklistShardingImpl.java:108"]; 201 [labelType="html" label="MapPartitionsRDD [201] [Unordered] count at WorklistShardingImpl.java:108"]; 202 [labelType="html" label="MapPartitionsRDD [202] [Unordered] count at WorklistShardingImpl.java:108"]; } subgraph cluster562 { label="WholeStageCodegen (1)"; 203 [labelType="html" label="MapPartitionsRDD [203] [Unordered] count at WorklistShardingImpl.java:108"]; } subgraph cluster561 { label="Exchange"; 204 [labelType="html" label="MapPartitionsRDD [204] [Unordered] count at WorklistShardingImpl.java:108"]; } } 188->189; 189->190; 190->191; 191->200; 200->201; 201->202; 202->203; 203->204; }

182,188

191

digraph G { subgraph clusterstage_75 { label="Stage 75 (skipped)"; subgraph cluster572 { label="AQEShuffleRead"; 205 [labelType="html" label="ShuffledRowRDD [205] [Unordered] count at WorklistShardingImpl.java:108"]; } subgraph cluster568 { label="WholeStageCodegen (2)"; 206 [labelType="html" label="MapPartitionsRDD [206] [Unordered] count at WorklistShardingImpl.java:108"]; } subgraph cluster567 { label="Exchange"; 207 [labelType="html" label="MapPartitionsRDD [207] [Unordered] count at WorklistShardingImpl.java:108"]; } } 205->206; 206->207; }

204,205

digraph G { subgraph clusterstage_76 { label="Stage 76"; subgraph cluster577 { label="Exchange"; 208 [labelType="html" label="ShuffledRowRDD [208] [Unordered] count at WorklistShardingImpl.java:108"]; } subgraph cluster573 { label="WholeStageCodegen (3)"; 209 [labelType="html" label="MapPartitionsRDD [209] [Unordered] count at WorklistShardingImpl.java:108"]; } subgraph cluster578 { label="mapPartitionsInternal"; 210 [labelType="html" label="MapPartitionsRDD [210] [Unordered] count at WorklistShardingImpl.java:108"]; } } 208->209; 209->210; }

207,208

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
76	tenants-pool-286	replenishmentRunId = 10000000095 tenantId = 6944346648028224943 activityType = CreateOrderProposalShards activityId = 26269996-b72a-3f7e-9814-66d8981041bd workflowType = CalculateOrderProposalsWorkflow workflowId = eba25ea7-bf45-3f36-ad32-cdab1a2c01e5 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD count at WorklistShardingImpl.java:108 +details org.apache.spark.sql.Dataset.count(Dataset.scala:3615) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.calculateBinPackingMetrics(WorklistShardingImpl.java:108) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.performBinPacking(WorklistShardingImpl.java:95) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.createWorklistShards(WorklistShardingImpl.java:38) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.OrderProposalGroupingShardingActivityImpl.createOrderProposalShards(OrderProposalGroupingShardingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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/02/06 06:54:51	16 ms	1/1			75.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

tenants-pool-286

replenishmentRunId = 10000000095 tenantId = 6944346648028224943 activityType = CreateOrderProposalShards activityId = 26269996-b72a-3f7e-9814-66d8981041bd workflowType = CalculateOrderProposalsWorkflow workflowId = eba25ea7-bf45-3f36-ad32-cdab1a2c01e5 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD count at WorklistShardingImpl.java:108 +details

org.apache.spark.sql.Dataset.count(Dataset.scala:3615)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.calculateBinPackingMetrics(WorklistShardingImpl.java:108)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.performBinPacking(WorklistShardingImpl.java:95)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.createWorklistShards(WorklistShardingImpl.java:38)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.OrderProposalGroupingShardingActivityImpl.createOrderProposalShards(OrderProposalGroupingShardingActivityImpl.java:62)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:105)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76)
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/02/06 06:54:51

16 ms

1/1

75.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
75	default	count at WorklistShardingImpl.java:108 +details org.apache.spark.sql.Dataset.count(Dataset.scala:3615) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.calculateBinPackingMetrics(WorklistShardingImpl.java:108) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.performBinPacking(WorklistShardingImpl.java:95) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.createWorklistShards(WorklistShardingImpl.java:38) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.OrderProposalGroupingShardingActivityImpl.createOrderProposalShards(OrderProposalGroupingShardingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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/1
74	default	count at WorklistShardingImpl.java:108 +details org.apache.spark.sql.Dataset.count(Dataset.scala:3615) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.calculateBinPackingMetrics(WorklistShardingImpl.java:108) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.performBinPacking(WorklistShardingImpl.java:95) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.createWorklistShards(WorklistShardingImpl.java:38) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.OrderProposalGroupingShardingActivityImpl.createOrderProposalShards(OrderProposalGroupingShardingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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/25
73	default	count at WorklistShardingImpl.java:107 +details org.apache.spark.sql.Dataset.count(Dataset.scala:3615) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.calculateBinPackingMetrics(WorklistShardingImpl.java:107) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.performBinPacking(WorklistShardingImpl.java:95) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.createWorklistShards(WorklistShardingImpl.java:38) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.OrderProposalGroupingShardingActivityImpl.createOrderProposalShards(OrderProposalGroupingShardingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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/25
72	default	count at WorklistShardingImpl.java:107 +details org.apache.spark.sql.Dataset.count(Dataset.scala:3615) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.calculateBinPackingMetrics(WorklistShardingImpl.java:107) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.performBinPacking(WorklistShardingImpl.java:95) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.createWorklistShards(WorklistShardingImpl.java:38) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.OrderProposalGroupingShardingActivityImpl.createOrderProposalShards(OrderProposalGroupingShardingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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/6

Page: