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

Status: SUCCEEDED
Submitted: 2026/02/06 10:33:42
Duration: 37 ms
Associated SQL Query: 101
Job Group: 716699f2-34fb-38b0-856a-57fc6af8628a
Completed Stages: 1
Skipped Stages: 3

Enable zooming

digraph G { subgraph clusterstage_403 { label="Stage 403 (skipped)"; subgraph cluster2703 { label="Scan parquet "; 1006 [labelType="html" label="FileScanRDD [1006] count at WorklistShardingImpl.java:107"]; 1007 [labelType="html" label="MapPartitionsRDD [1007] count at WorklistShardingImpl.java:107"]; } subgraph cluster2699 { label="WholeStageCodegen (1)"; 1008 [labelType="html" label="MapPartitionsRDD [1008] count at WorklistShardingImpl.java:107"]; } subgraph cluster2698 { label="Exchange"; 1009 [labelType="html" label="MapPartitionsRDD [1009] count at WorklistShardingImpl.java:107"]; 1010 [labelType="html" label="MapPartitionsRDD [1010] count at WorklistShardingImpl.java:107"]; } } 1006->1007; 1007->1008; 1008->1009; 1009->1010; }

digraph G { subgraph clusterstage_404 { label="Stage 404 (skipped)"; subgraph cluster2738 { label="Exchange"; 1026 [labelType="html" label="ShuffledRowRDD [1026] [Unordered] count at WorklistShardingImpl.java:107"]; } subgraph cluster2736 { label="Exchange"; 1027 [labelType="html" label="MapPartitionsRDD [1027] [Unordered] count at WorklistShardingImpl.java:107"]; } } 1026->1027; }

1010,1026

digraph G { subgraph clusterstage_405 { label="Stage 405 (skipped)"; subgraph cluster2761 { label="Exchange"; 1030 [labelType="html" label="ShuffledRowRDD [1030] [Unordered] count at WorklistShardingImpl.java:107"]; } subgraph cluster2751 { label="WholeStageCodegen (5)"; 1031 [labelType="html" label="MapPartitionsRDD [1031] [Unordered] count at WorklistShardingImpl.java:107"]; } subgraph cluster2762 { label="mapPartitionsInternal"; 1032 [labelType="html" label="MapPartitionsRDD [1032] [Unordered] count at WorklistShardingImpl.java:107"]; } subgraph cluster2763 { label="mapPartitionsInternal"; 1033 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, productOrderScheduleExploded#32769.product AS product#32783, productOrderScheduleExploded#32769.orderDateTime AS orderDateTime#32784, productOrderScheduleExploded#32769.availabilityDateTime AS availabilityDateTime#32785, productOrderScheduleExploded#32769.nextAvailabilityDateTime AS nextAvailabilityDateTime#32786, productOrderScheduleExploded#32769.mrpController AS mrpController#32787, productOrderScheduleExploded#32769.sourceOfSupplyUuid AS sourceOfSupplyUuid#32788, productOrderScheduleExploded#32769.purchasingOrg AS purchasingOrg#32789, productOrderScheduleExploded#32769.purchasingGroup AS purchasingGroup#32790, xxhash64(CASE WHEN (_extract_supplier#33643 <=> true) THEN supplierOrGroup#32676 END, CASE WHEN (_extract_deliveryDate#33644 <=> true) THEN deliveryDateTime#32470 END, CASE WHEN (_extract_orderDate#33645 <=> true) THEN productOrderScheduleExploded#32769.orderDa... [1033] [Cached] [Unordered] count at WorklistShardingImpl.java:107"]; } subgraph cluster2832 { label="InMemoryTableScan"; 1053 [labelType="html" label="MapPartitionsRDD [1053] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 1054 [labelType="html" label="MapPartitionsRDD [1054] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 1055 [labelType="html" label="MapPartitionsRDD [1055] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster2830 { label="Exchange"; 1056 [labelType="html" label="MapPartitionsRDD [1056] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } } 1030->1031; 1031->1032; 1032->1033; 1033->1053; 1053->1054; 1054->1055; 1055->1056; }

1027,1030

1033

digraph G { subgraph clusterstage_406 { label="Stage 406"; subgraph cluster2834 { label="Exchange"; 1057 [labelType="html" label="ShuffledRowRDD [1057] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster2828 { label="AdaptiveSparkPlan"; 1058 [labelType="html" label="MapPartitionsRDD [1058] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 1059 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=11089]\n +- InMemoryTableScan [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, product#32783, orderDateTime#32784, availabilityDateTime#32785, nextAvailabilityDateTime#32786, mrpController#32787, sourceOfSupplyUuid#32788, purchasingOrg#32789, purchasingGroup#32790, orderProposalId#33183L, orderProposalHorizonGroupingId#33204L, splitIndicator#33604L]\n +- InMemoryRelation [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, product#32783, orderDateTime#32784, availabilityDateTime#32785, nextAvailabilityDateTime#32786, mrpController#32787, sourceOfSupplyUuid#32788, purchasingOrg#32789, purchasingGroup#32790, orderProposalId#33183L, orderProposalHorizonGroupingId#33204L, splitIndicator#33604L], StorageLevel(disk, memory, 2 replicas)\n +- AdaptiveSparkPlan isFinalPlan=true\n +- == Final Plan ==\n ... [1059] [Cached] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster2841 { label="InMemoryTableScan"; 1060 [labelType="html" label="MapPartitionsRDD [1060] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 1061 [labelType="html" label="MapPartitionsRDD [1061] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 1062 [labelType="html" label="MapPartitionsRDD [1062] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster2839 { label="DeserializeToObject"; 1063 [labelType="html" label="MapPartitionsRDD [1063] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster2838 { label="MapPartitions"; 1064 [labelType="html" label="MapPartitionsRDD [1064] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster2835 { label="WholeStageCodegen (1)"; 1065 [labelType="html" label="MapPartitionsRDD [1065] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster2827 { label="AdaptiveSparkPlan"; 1066 [labelType="html" label="MapPartitionsRDD [1066] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 1067 [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#35312, 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#35313, 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(inp... [1067] [Cached] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster2847 { label="InMemoryTableScan"; 1068 [labelType="html" label="MapPartitionsRDD [1068] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 1069 [labelType="html" label="MapPartitionsRDD [1069] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 1070 [labelType="html" label="MapPartitionsRDD [1070] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster2842 { label="WholeStageCodegen (1)"; 1071 [labelType="html" label="MapPartitionsRDD [1071] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster2848 { label="mapPartitionsInternal"; 1072 [labelType="html" label="MapPartitionsRDD [1072] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster2849 { label="mapPartitionsInternal"; 1073 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [supplierGroup#35312, supplier#35313, plant#35314, deliveryDateTime#35315, subrange#35316, product#35317, orderDateTime#35318, availabilityDateTime#35319, nextAvailabilityDateTime#35320, mrpController#35321, sourceOfSupplyUuid#35322, purchasingOrg#35323, purchasingGroup#35324, orderProposalId#35325L, orderProposalHorizonGroupingId#35326L, splitIndicator#35327L, shardId#35654, worklistShardItemId#35690L, null AS orderProposalItemGroupId#35709, cast((monotonically_increasing_id() % 9999999999) as string) AS orderProposalItemId#35729]\n +- Project [supplierGroup#35312, supplier#35313, plant#35314, deliveryDateTime#35315, subrange#35316, product#35317, orderDateTime#35318, availabilityDateTime#35319, nextAvailabilityDateTime#35320, mrpController#35321, sourceOfSupplyUuid#35322, purchasingOrg#35323, purchasingGroup#35324, orderProposalId#35325L, orderProposalHorizonGroupingId#35326L, splitIndicator#35327L, concat(0, _, cast(binId#35328 as string), _, 10000000096) ... [1073] [Cached] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster2855 { label="InMemoryTableScan"; 1074 [labelType="html" label="MapPartitionsRDD [1074] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 1075 [labelType="html" label="MapPartitionsRDD [1075] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; 1076 [labelType="html" label="MapPartitionsRDD [1076] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster2850 { label="WholeStageCodegen (1)"; 1077 [labelType="html" label="MapPartitionsRDD [1077] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } subgraph cluster2856 { label="mapPartitionsInternal"; 1078 [labelType="html" label="MapPartitionsRDD [1078] [Unordered] collectAsList at FileStorageAdapterImpl.java:260"]; } } 1057->1058; 1058->1059; 1059->1060; 1060->1061; 1061->1062; 1062->1063; 1063->1064; 1064->1065; 1065->1066; 1066->1067; 1067->1068; 1068->1069; 1069->1070; 1070->1071; 1071->1072; 1072->1073; 1073->1074; 1074->1075; 1075->1076; 1076->1077; 1077->1078; }

1056,1057

1059

1067

1073

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
406	tenants-pool-286	replenishmentRunId = 10000000096 tenantId = 6944346648028224943 activityType = CreateOrderProposalShards activityId = 716699f2-34fb-38b0-856a-57fc6af8628a workflowType = CalculateOrderProposalsWorkflow workflowId = 9e4477b5-be60-3834-83e9-5b127657b9b8 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 10:33:42	34 ms	1/1	35.7 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

406

tenants-pool-286

replenishmentRunId = 10000000096 tenantId = 6944346648028224943 activityType = CreateOrderProposalShards activityId = 716699f2-34fb-38b0-856a-57fc6af8628a workflowType = CalculateOrderProposalsWorkflow workflowId = 9e4477b5-be60-3834-83e9-5b127657b9b8 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 10:33:42

34 ms

1/1

35.7 KiB

Page:

Skipped Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
405	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
404	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
403	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

405

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

404

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

403

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: