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

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

Enable zooming

digraph G { subgraph clusterstage_92 { label="Stage 92 (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_93 { label="Stage 93 (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_94 { label="Stage 94 (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 cluster597 { label="InMemoryTableScan"; 211 [labelType="html" label="MapPartitionsRDD [211] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 212 [labelType="html" label="MapPartitionsRDD [212] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 213 [labelType="html" label="MapPartitionsRDD [213] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster595 { label="Exchange"; 214 [labelType="html" label="MapPartitionsRDD [214] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } } 188->189; 189->190; 190->191; 191->211; 211->212; 212->213; 213->214; }

182,188

191

digraph G { subgraph clusterstage_95 { label="Stage 95"; subgraph cluster599 { label="Exchange"; 215 [labelType="html" label="ShuffledRowRDD [215] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster593 { label="AdaptiveSparkPlan"; 216 [labelType="html" label="MapPartitionsRDD [216] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 217 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=2208]\n +- InMemoryTableScan [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, product#3315, orderDateTime#3316, availabilityDateTime#3317, nextAvailabilityDateTime#3318, mrpController#3319, sourceOfSupplyUuid#3320, purchasingOrg#3321, purchasingGroup#3322, orderProposalId#3715L, orderProposalHorizonGroupingId#3736L, splitIndicator#4136L]\n +- InMemoryRelation [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, product#3315, orderDateTime#3316, availabilityDateTime#3317, nextAvailabilityDateTime#3318, mrpController#3319, sourceOfSupplyUuid#3320, purchasingOrg#3321, purchasingGroup#3322, orderProposalId#3715L, orderProposalHorizonGroupingId#3736L, splitIndicator#4136L], StorageLevel(disk, memory, 2 replicas)\n +- AdaptiveSparkPlan isFinalPlan=true\n +- == Final Plan ==\n *(5) Project [suppli... [217] [Cached] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster606 { label="InMemoryTableScan"; 218 [labelType="html" label="MapPartitionsRDD [218] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 219 [labelType="html" label="MapPartitionsRDD [219] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 220 [labelType="html" label="MapPartitionsRDD [220] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster604 { label="DeserializeToObject"; 221 [labelType="html" label="MapPartitionsRDD [221] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster603 { label="MapPartitions"; 222 [labelType="html" label="MapPartitionsRDD [222] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster600 { label="WholeStageCodegen (1)"; 223 [labelType="html" label="MapPartitionsRDD [223] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster592 { label="AdaptiveSparkPlan"; 224 [labelType="html" label="MapPartitionsRDD [224] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 225 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- SerializeFromObject [if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 0, supplierGroup), StringType, ObjectType(class java.lang.String)), true, false, true) AS supplierGroup#5844, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 1, supplier), StringType, ObjectType(class java.lang.String)), true, false, true) AS supplier#5845, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input... [225] [Cached] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster612 { label="InMemoryTableScan"; 226 [labelType="html" label="MapPartitionsRDD [226] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 227 [labelType="html" label="MapPartitionsRDD [227] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 228 [labelType="html" label="MapPartitionsRDD [228] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster607 { label="WholeStageCodegen (1)"; 229 [labelType="html" label="MapPartitionsRDD [229] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster613 { label="mapPartitionsInternal"; 230 [labelType="html" label="MapPartitionsRDD [230] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster614 { label="mapPartitionsInternal"; 231 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [supplierGroup#5844, supplier#5845, plant#5846, deliveryDateTime#5847, subrange#5848, product#5849, orderDateTime#5850, availabilityDateTime#5851, nextAvailabilityDateTime#5852, mrpController#5853, sourceOfSupplyUuid#5854, purchasingOrg#5855, purchasingGroup#5856, orderProposalId#5857L, orderProposalHorizonGroupingId#5858L, splitIndicator#5859L, shardId#6186, worklistShardItemId#6222L, null AS orderProposalItemGroupId#6241, cast((monotonically_increasing_id() % 9999999999) as string) AS orderProposalItemId#6261]\n +- Project [supplierGroup#5844, supplier#5845, plant#5846, deliveryDateTime#5847, subrange#5848, product#5849, orderDateTime#5850, availabilityDateTime#5851, nextAvailabilityDateTime#5852, mrpController#5853, sourceOfSupplyUuid#5854, purchasingOrg#5855, purchasingGroup#5856, orderProposalId#5857L, orderProposalHorizonGroupingId#5858L, splitIndicator#5859L, concat(0, _, cast(binId#5860 as string), _, 10000000095) AS shardId#6186, monotonically_increa... [231] [Cached] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster620 { label="InMemoryTableScan"; 232 [labelType="html" label="MapPartitionsRDD [232] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 233 [labelType="html" label="MapPartitionsRDD [233] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 234 [labelType="html" label="MapPartitionsRDD [234] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster615 { label="WholeStageCodegen (1)"; 235 [labelType="html" label="MapPartitionsRDD [235] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster621 { label="mapPartitionsInternal"; 236 [labelType="html" label="MapPartitionsRDD [236] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } } 215->216; 216->217; 217->218; 218->219; 219->220; 220->221; 221->222; 222->223; 223->224; 224->225; 225->226; 226->227; 227->228; 228->229; 229->230; 230->231; 231->232; 232->233; 233->234; 234->235; 235->236; }

214,215

217

225

231

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
95	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 collectAsList at FileStorageAdapterImpl.java:260 +details org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:3586) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.urlByShard(FileStorageAdapterImpl.java:260) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeShardedWorklist(FileStorageAdapterImpl.java:243) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.WorklistShardGenerationDataAccessImpl.storeShardWorklists(WorklistShardGenerationDataAccessImpl.java:26) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.WorklistShardGenerationDataAccessImpl.storeShardWorklists(WorklistShardGenerationDataAccessImpl.java:35) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.createWorklistShards(WorklistShardingImpl.java:45) 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)	2026/02/06 06:54:52	55 ms	1/1	35.6 KiB

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 collectAsList at FileStorageAdapterImpl.java:260 +details

org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:3586)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.urlByShard(FileStorageAdapterImpl.java:260)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeShardedWorklist(FileStorageAdapterImpl.java:243)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.WorklistShardGenerationDataAccessImpl.storeShardWorklists(WorklistShardGenerationDataAccessImpl.java:26)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.WorklistShardGenerationDataAccessImpl.storeShardWorklists(WorklistShardGenerationDataAccessImpl.java:35)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.createWorklistShards(WorklistShardingImpl.java:45)
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)

2026/02/06 06:54:52

55 ms

1/1

35.6 KiB

Page:

Skipped Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
94	default	collectAsList at FileStorageAdapterImpl.java:260 +details org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:3586) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.urlByShard(FileStorageAdapterImpl.java:260) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeShardedWorklist(FileStorageAdapterImpl.java:243) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.WorklistShardGenerationDataAccessImpl.storeShardWorklists(WorklistShardGenerationDataAccessImpl.java:26) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.WorklistShardGenerationDataAccessImpl.storeShardWorklists(WorklistShardGenerationDataAccessImpl.java:35) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.createWorklistShards(WorklistShardingImpl.java:45) 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)	Unknown	Unknown	0/25
93	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
92	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

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

default

collectAsList at FileStorageAdapterImpl.java:260 +details

org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:3586)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.urlByShard(FileStorageAdapterImpl.java:260)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storeShardedWorklist(FileStorageAdapterImpl.java:243)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.WorklistShardGenerationDataAccessImpl.storeShardWorklists(WorklistShardGenerationDataAccessImpl.java:26)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.WorklistShardGenerationDataAccessImpl.storeShardWorklists(WorklistShardGenerationDataAccessImpl.java:35)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.grouping.WorklistShardingImpl.createWorklistShards(WorklistShardingImpl.java:45)
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)

Unknown

0/25

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

0/25

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

0/6

Page: