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

Status: SUCCEEDED
Submitted: 2026/02/06 10:33:29
Duration: 0.6 s
Associated SQL Query: 93
Job Group: e8bbd528-e182-393f-b737-ebededb77cbf
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { subgraph clusterstage_342 { label="Stage 342 (skipped)"; subgraph cluster2538 { label="LocalTableScan"; 949 [labelType="html" label="ParallelCollectionRDD [949] save at FileStorageAdapterImpl.java:755"]; 950 [labelType="html" label="MapPartitionsRDD [950] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2537 { label="Exchange"; 951 [labelType="html" label="MapPartitionsRDD [951] save at FileStorageAdapterImpl.java:755"]; } } 949->950; 950->951; }

digraph G { subgraph clusterstage_343 { label="Stage 343 (skipped)"; subgraph cluster2536 { label="LocalTableScan"; 946 [labelType="html" label="ParallelCollectionRDD [946] save at FileStorageAdapterImpl.java:755"]; 947 [labelType="html" label="MapPartitionsRDD [947] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2535 { label="Exchange"; 948 [labelType="html" label="MapPartitionsRDD [948] save at FileStorageAdapterImpl.java:755"]; } } 946->947; 947->948; }

digraph G { subgraph clusterstage_344 { label="Stage 344 (skipped)"; subgraph cluster2549 { label="AQEShuffleRead"; 955 [labelType="html" label="ShuffledRowRDD [955] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2546 { label="WholeStageCodegen (1)"; 956 [labelType="html" label="MapPartitionsRDD [956] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2554 { label="AQEShuffleRead"; 957 [labelType="html" label="ShuffledRowRDD [957] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2551 { label="WholeStageCodegen (2)"; 958 [labelType="html" label="MapPartitionsRDD [958] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2542 { label="WholeStageCodegen (3)"; 959 [labelType="html" label="ZippedPartitionsRDD2 [959] [Unordered] save at FileStorageAdapterImpl.java:755"]; 960 [labelType="html" label="MapPartitionsRDD [960] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2541 { label="Exchange"; 961 [labelType="html" label="MapPartitionsRDD [961] [Unordered] save at FileStorageAdapterImpl.java:755"]; } } 955->956; 957->958; 956->959; 958->959; 959->960; 960->961; }

948,955

951,957

digraph G { subgraph clusterstage_345 { label="Stage 345 (skipped)"; subgraph cluster2540 { label="LocalTableScan"; 952 [labelType="html" label="ParallelCollectionRDD [952] save at FileStorageAdapterImpl.java:755"]; 953 [labelType="html" label="MapPartitionsRDD [953] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2539 { label="Exchange"; 954 [labelType="html" label="MapPartitionsRDD [954] save at FileStorageAdapterImpl.java:755"]; } } 952->953; 953->954; }

digraph G { subgraph clusterstage_346 { label="Stage 346"; subgraph cluster2564 { label="AQEShuffleRead"; 962 [labelType="html" label="ShuffledRowRDD [962] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2561 { label="WholeStageCodegen (4)"; 963 [labelType="html" label="MapPartitionsRDD [963] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2569 { label="AQEShuffleRead"; 964 [labelType="html" label="ShuffledRowRDD [964] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2566 { label="WholeStageCodegen (5)"; 965 [labelType="html" label="MapPartitionsRDD [965] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2556 { label="WholeStageCodegen (6)"; 966 [labelType="html" label="ZippedPartitionsRDD2 [966] [Unordered] save at FileStorageAdapterImpl.java:755"]; 967 [labelType="html" label="MapPartitionsRDD [967] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2555 { label="WriteFiles"; 968 [labelType="html" label="MapPartitionsRDD [968] [Unordered] save at FileStorageAdapterImpl.java:755"]; } } 962->963; 964->965; 963->966; 965->966; 966->967; 967->968; }

961,962

954,964

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
346	tenants-pool-286	replenishmentRunId = 10000000096 tenantId = 6944346648028224943 activityType = EnhanceWorklistByAttributes activityId = e8bbd528-e182-393f-b737-ebededb77cbf workflowType = CalculateOrderProposalsWorkflow workflowId = 9e4477b5-be60-3834-83e9-5b127657b9b8 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD save at FileStorageAdapterImpl.java:755 +details org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:243) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:755) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.WorklistAttributeEnhancementActivityImpl.enhanceWorklistByAttributes(WorklistAttributeEnhancementActivityImpl.java:50) 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 10:33:29	0.6 s	1/1		33.7 KiB	5.1 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

346

tenants-pool-286

replenishmentRunId = 10000000096 tenantId = 6944346648028224943 activityType = EnhanceWorklistByAttributes activityId = e8bbd528-e182-393f-b737-ebededb77cbf workflowType = CalculateOrderProposalsWorkflow workflowId = 9e4477b5-be60-3834-83e9-5b127657b9b8 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD save at FileStorageAdapterImpl.java:755 +details

org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:243)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:755)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.WorklistAttributeEnhancementActivityImpl.enhanceWorklistByAttributes(WorklistAttributeEnhancementActivityImpl.java:50)
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 10:33:29

0.6 s

1/1

33.7 KiB

5.1 KiB

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
345	default	save at FileStorageAdapterImpl.java:755 +details org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:243) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:755) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.WorklistAttributeEnhancementActivityImpl.enhanceWorklistByAttributes(WorklistAttributeEnhancementActivityImpl.java:50) 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/17
344	default	save at FileStorageAdapterImpl.java:755 +details org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:243) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:755) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.WorklistAttributeEnhancementActivityImpl.enhanceWorklistByAttributes(WorklistAttributeEnhancementActivityImpl.java:50) 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
343	default	save at FileStorageAdapterImpl.java:755 +details org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:243) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:755) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.WorklistAttributeEnhancementActivityImpl.enhanceWorklistByAttributes(WorklistAttributeEnhancementActivityImpl.java:50) 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/17
342	default	save at FileStorageAdapterImpl.java:755 +details org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:243) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.storePerformanceMetrics(FileStorageAdapterImpl.java:755) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.grouping.WorklistAttributeEnhancementActivityImpl.enhanceWorklistByAttributes(WorklistAttributeEnhancementActivityImpl.java:50) 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/17

Page: