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

Status: SUCCEEDED
Submitted: 2026/02/06 10:34:01
Duration: 0.5 s
Associated SQL Query: 120
Job Group: aab19991-4480-31e0-94d1-1e3872bbff2f
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { subgraph clusterstage_490 { label="Stage 490 (skipped)"; subgraph cluster3360 { label="LocalTableScan"; 1277 [labelType="html" label="ParallelCollectionRDD [1277] save at FileStorageAdapterImpl.java:755"]; 1278 [labelType="html" label="MapPartitionsRDD [1278] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3359 { label="Exchange"; 1279 [labelType="html" label="MapPartitionsRDD [1279] save at FileStorageAdapterImpl.java:755"]; } } 1277->1278; 1278->1279; }

digraph G { subgraph clusterstage_491 { label="Stage 491 (skipped)"; subgraph cluster3362 { label="LocalTableScan"; 1280 [labelType="html" label="ParallelCollectionRDD [1280] save at FileStorageAdapterImpl.java:755"]; 1281 [labelType="html" label="MapPartitionsRDD [1281] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3361 { label="Exchange"; 1282 [labelType="html" label="MapPartitionsRDD [1282] save at FileStorageAdapterImpl.java:755"]; } } 1280->1281; 1281->1282; }

digraph G { subgraph clusterstage_492 { label="Stage 492 (skipped)"; subgraph cluster3373 { label="AQEShuffleRead"; 1286 [labelType="html" label="ShuffledRowRDD [1286] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3370 { label="WholeStageCodegen (1)"; 1287 [labelType="html" label="MapPartitionsRDD [1287] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3378 { label="AQEShuffleRead"; 1288 [labelType="html" label="ShuffledRowRDD [1288] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3375 { label="WholeStageCodegen (2)"; 1289 [labelType="html" label="MapPartitionsRDD [1289] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3366 { label="WholeStageCodegen (3)"; 1290 [labelType="html" label="ZippedPartitionsRDD2 [1290] [Unordered] save at FileStorageAdapterImpl.java:755"]; 1291 [labelType="html" label="MapPartitionsRDD [1291] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3365 { label="Exchange"; 1292 [labelType="html" label="MapPartitionsRDD [1292] [Unordered] save at FileStorageAdapterImpl.java:755"]; } } 1286->1287; 1288->1289; 1287->1290; 1289->1290; 1290->1291; 1291->1292; }

1279,1286

1282,1288

digraph G { subgraph clusterstage_493 { label="Stage 493 (skipped)"; subgraph cluster3364 { label="LocalTableScan"; 1283 [labelType="html" label="ParallelCollectionRDD [1283] save at FileStorageAdapterImpl.java:755"]; 1284 [labelType="html" label="MapPartitionsRDD [1284] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3363 { label="Exchange"; 1285 [labelType="html" label="MapPartitionsRDD [1285] save at FileStorageAdapterImpl.java:755"]; } } 1283->1284; 1284->1285; }

digraph G { subgraph clusterstage_494 { label="Stage 494"; subgraph cluster3388 { label="AQEShuffleRead"; 1293 [labelType="html" label="ShuffledRowRDD [1293] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3385 { label="WholeStageCodegen (4)"; 1294 [labelType="html" label="MapPartitionsRDD [1294] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3393 { label="AQEShuffleRead"; 1295 [labelType="html" label="ShuffledRowRDD [1295] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3390 { label="WholeStageCodegen (5)"; 1296 [labelType="html" label="MapPartitionsRDD [1296] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3380 { label="WholeStageCodegen (6)"; 1297 [labelType="html" label="ZippedPartitionsRDD2 [1297] [Unordered] save at FileStorageAdapterImpl.java:755"]; 1298 [labelType="html" label="MapPartitionsRDD [1298] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3379 { label="WriteFiles"; 1299 [labelType="html" label="MapPartitionsRDD [1299] [Unordered] save at FileStorageAdapterImpl.java:755"]; } } 1293->1294; 1295->1296; 1294->1297; 1296->1297; 1297->1298; 1298->1299; }

1292,1293

1285,1295

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
494	tenants-pool-286	replenishmentRunId = 10000000096 tenantId = 6944346648028224943 activityType = CreateProdPlantList activityId = aab19991-4480-31e0-94d1-1e3872bbff2f workflowType = ProcessWorkloadShardWorkflow workflowId = 9853fdbb-cc51-3855-a9da-9170fc5b0400 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 10:34:01	0.5 s	1/1		31.0 KiB	754.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

494

tenants-pool-286

replenishmentRunId = 10000000096 tenantId = 6944346648028224943 activityType = CreateProdPlantList activityId = aab19991-4480-31e0-94d1-1e3872bbff2f workflowType = ProcessWorkloadShardWorkflow workflowId = 9853fdbb-cc51-3855-a9da-9170fc5b0400 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 10:34:01

0.5 s

1/1

31.0 KiB

754.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
493	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
492	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
491	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
490	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: