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

Status: SUCCEEDED
Submitted: 2026/02/06 06:54:25
Duration: 0.6 s
Associated SQL Query: 14
Job Group: b191ef00-edf7-38ea-9e23-db676456ad33
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { subgraph clusterstage_31 { label="Stage 31 (skipped)"; subgraph cluster303 { label="LocalTableScan"; 107 [labelType="html" label="ParallelCollectionRDD [107] save at FileStorageAdapterImpl.java:755"]; 108 [labelType="html" label="MapPartitionsRDD [108] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster302 { label="Exchange"; 109 [labelType="html" label="MapPartitionsRDD [109] save at FileStorageAdapterImpl.java:755"]; } } 107->108; 108->109; }

digraph G { subgraph clusterstage_32 { label="Stage 32 (skipped)"; subgraph cluster301 { label="LocalTableScan"; 104 [labelType="html" label="ParallelCollectionRDD [104] save at FileStorageAdapterImpl.java:755"]; 105 [labelType="html" label="MapPartitionsRDD [105] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster300 { label="Exchange"; 106 [labelType="html" label="MapPartitionsRDD [106] save at FileStorageAdapterImpl.java:755"]; } } 104->105; 105->106; }

digraph G { subgraph clusterstage_33 { label="Stage 33 (skipped)"; subgraph cluster314 { label="AQEShuffleRead"; 113 [labelType="html" label="ShuffledRowRDD [113] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster311 { label="WholeStageCodegen (1)"; 114 [labelType="html" label="MapPartitionsRDD [114] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster319 { label="AQEShuffleRead"; 115 [labelType="html" label="ShuffledRowRDD [115] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster316 { label="WholeStageCodegen (2)"; 116 [labelType="html" label="MapPartitionsRDD [116] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster307 { label="WholeStageCodegen (3)"; 117 [labelType="html" label="ZippedPartitionsRDD2 [117] [Unordered] save at FileStorageAdapterImpl.java:755"]; 118 [labelType="html" label="MapPartitionsRDD [118] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster306 { label="Exchange"; 119 [labelType="html" label="MapPartitionsRDD [119] [Unordered] save at FileStorageAdapterImpl.java:755"]; } } 113->114; 115->116; 114->117; 116->117; 117->118; 118->119; }

106,113

109,115

digraph G { subgraph clusterstage_34 { label="Stage 34 (skipped)"; subgraph cluster305 { label="LocalTableScan"; 110 [labelType="html" label="ParallelCollectionRDD [110] save at FileStorageAdapterImpl.java:755"]; 111 [labelType="html" label="MapPartitionsRDD [111] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster304 { label="Exchange"; 112 [labelType="html" label="MapPartitionsRDD [112] save at FileStorageAdapterImpl.java:755"]; } } 110->111; 111->112; }

digraph G { subgraph clusterstage_35 { label="Stage 35"; subgraph cluster329 { label="AQEShuffleRead"; 120 [labelType="html" label="ShuffledRowRDD [120] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster326 { label="WholeStageCodegen (4)"; 121 [labelType="html" label="MapPartitionsRDD [121] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster334 { label="AQEShuffleRead"; 122 [labelType="html" label="ShuffledRowRDD [122] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster331 { label="WholeStageCodegen (5)"; 123 [labelType="html" label="MapPartitionsRDD [123] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster321 { label="WholeStageCodegen (6)"; 124 [labelType="html" label="ZippedPartitionsRDD2 [124] [Unordered] save at FileStorageAdapterImpl.java:755"]; 125 [labelType="html" label="MapPartitionsRDD [125] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster320 { label="WriteFiles"; 126 [labelType="html" label="MapPartitionsRDD [126] [Unordered] save at FileStorageAdapterImpl.java:755"]; } } 120->121; 122->123; 121->124; 123->124; 124->125; 125->126; }

119,120

112,122

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
35	tenants-pool-286	replenishmentRunId = 10000000095 tenantId = 6944346648028224943 activityType = EnhanceWorklistByAttributes activityId = b191ef00-edf7-38ea-9e23-db676456ad33 workflowType = CalculateOrderProposalsWorkflow workflowId = eba25ea7-bf45-3f36-ad32-cdab1a2c01e5 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 06:54:25	0.6 s	1/1		33.7 KiB	5.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 = EnhanceWorklistByAttributes activityId = b191ef00-edf7-38ea-9e23-db676456ad33 workflowType = CalculateOrderProposalsWorkflow workflowId = eba25ea7-bf45-3f36-ad32-cdab1a2c01e5 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 06:54:25

0.6 s

1/1

33.7 KiB

5.6 KiB

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
34	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
33	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
32	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
31	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: