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

Status: SUCCEEDED
Submitted: 2026/02/06 06:55:22
Duration: 0.5 s
Associated SQL Query: 41
Job Group: 26b1f0cb-25a8-3510-a51b-f851585c09a0
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { subgraph clusterstage_179 { label="Stage 179 (skipped)"; subgraph cluster1127 { label="LocalTableScan"; 438 [labelType="html" label="ParallelCollectionRDD [438] save at FileStorageAdapterImpl.java:755"]; 439 [labelType="html" label="MapPartitionsRDD [439] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster1126 { label="Exchange"; 440 [labelType="html" label="MapPartitionsRDD [440] save at FileStorageAdapterImpl.java:755"]; } } 438->439; 439->440; }

digraph G { subgraph clusterstage_180 { label="Stage 180 (skipped)"; subgraph cluster1125 { label="LocalTableScan"; 435 [labelType="html" label="ParallelCollectionRDD [435] save at FileStorageAdapterImpl.java:755"]; 436 [labelType="html" label="MapPartitionsRDD [436] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster1124 { label="Exchange"; 437 [labelType="html" label="MapPartitionsRDD [437] save at FileStorageAdapterImpl.java:755"]; } } 435->436; 436->437; }

digraph G { subgraph clusterstage_181 { label="Stage 181 (skipped)"; subgraph cluster1138 { label="AQEShuffleRead"; 444 [labelType="html" label="ShuffledRowRDD [444] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster1135 { label="WholeStageCodegen (1)"; 445 [labelType="html" label="MapPartitionsRDD [445] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster1143 { label="AQEShuffleRead"; 446 [labelType="html" label="ShuffledRowRDD [446] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster1140 { label="WholeStageCodegen (2)"; 447 [labelType="html" label="MapPartitionsRDD [447] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster1131 { label="WholeStageCodegen (3)"; 448 [labelType="html" label="ZippedPartitionsRDD2 [448] [Unordered] save at FileStorageAdapterImpl.java:755"]; 449 [labelType="html" label="MapPartitionsRDD [449] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster1130 { label="Exchange"; 450 [labelType="html" label="MapPartitionsRDD [450] [Unordered] save at FileStorageAdapterImpl.java:755"]; } } 444->445; 446->447; 445->448; 447->448; 448->449; 449->450; }

437,444

440,446

digraph G { subgraph clusterstage_182 { label="Stage 182 (skipped)"; subgraph cluster1129 { label="LocalTableScan"; 441 [labelType="html" label="ParallelCollectionRDD [441] save at FileStorageAdapterImpl.java:755"]; 442 [labelType="html" label="MapPartitionsRDD [442] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster1128 { label="Exchange"; 443 [labelType="html" label="MapPartitionsRDD [443] save at FileStorageAdapterImpl.java:755"]; } } 441->442; 442->443; }

digraph G { subgraph clusterstage_183 { label="Stage 183"; subgraph cluster1153 { label="AQEShuffleRead"; 451 [labelType="html" label="ShuffledRowRDD [451] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster1150 { label="WholeStageCodegen (4)"; 452 [labelType="html" label="MapPartitionsRDD [452] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster1158 { label="AQEShuffleRead"; 453 [labelType="html" label="ShuffledRowRDD [453] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster1155 { label="WholeStageCodegen (5)"; 454 [labelType="html" label="MapPartitionsRDD [454] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster1145 { label="WholeStageCodegen (6)"; 455 [labelType="html" label="ZippedPartitionsRDD2 [455] [Unordered] save at FileStorageAdapterImpl.java:755"]; 456 [labelType="html" label="MapPartitionsRDD [456] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster1144 { label="WriteFiles"; 457 [labelType="html" label="MapPartitionsRDD [457] [Unordered] save at FileStorageAdapterImpl.java:755"]; } } 451->452; 453->454; 452->455; 454->455; 455->456; 456->457; }

450,451

443,453

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
183	tenants-pool-286	replenishmentRunId = 10000000095 tenantId = 6944346648028224943 activityType = CreateProdPlantList activityId = 26b1f0cb-25a8-3510-a51b-f851585c09a0 workflowType = ProcessWorkloadShardWorkflow workflowId = 06426dca-6324-34ce-8244-a807b69efd73 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.CreateProdPlantListForShardActivityImpl.createProdPlantList(CreateProdPlantListForShardActivityImpl.java:45) 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:55:22	0.4 s	1/1		30.9 KiB	930.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

183

tenants-pool-286

replenishmentRunId = 10000000095 tenantId = 6944346648028224943 activityType = CreateProdPlantList activityId = 26b1f0cb-25a8-3510-a51b-f851585c09a0 workflowType = ProcessWorkloadShardWorkflow workflowId = 06426dca-6324-34ce-8244-a807b69efd73 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.CreateProdPlantListForShardActivityImpl.createProdPlantList(CreateProdPlantListForShardActivityImpl.java:45)
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:55:22

0.4 s

1/1

30.9 KiB

930.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
182	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.CreateProdPlantListForShardActivityImpl.createProdPlantList(CreateProdPlantListForShardActivityImpl.java:45) 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/3
181	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.CreateProdPlantListForShardActivityImpl.createProdPlantList(CreateProdPlantListForShardActivityImpl.java:45) 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
180	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.CreateProdPlantListForShardActivityImpl.createProdPlantList(CreateProdPlantListForShardActivityImpl.java:45) 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/3
179	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.CreateProdPlantListForShardActivityImpl.createProdPlantList(CreateProdPlantListForShardActivityImpl.java:45) 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/3

Page: