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

Status: SUCCEEDED
Submitted: 2026/02/06 10:33:46
Duration: 0.4 s
Associated SQL Query: 108
Job Group: e3aeb3ac-cdab-38d4-8651-88ee8ccad2a4
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { subgraph clusterstage_434 { label="Stage 434 (skipped)"; subgraph cluster2994 { label="LocalTableScan"; 1120 [labelType="html" label="ParallelCollectionRDD [1120] save at FileStorageAdapterImpl.java:755"]; 1121 [labelType="html" label="MapPartitionsRDD [1121] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2993 { label="Exchange"; 1122 [labelType="html" label="MapPartitionsRDD [1122] save at FileStorageAdapterImpl.java:755"]; } } 1120->1121; 1121->1122; }

digraph G { subgraph clusterstage_435 { label="Stage 435 (skipped)"; subgraph cluster2996 { label="LocalTableScan"; 1123 [labelType="html" label="ParallelCollectionRDD [1123] save at FileStorageAdapterImpl.java:755"]; 1124 [labelType="html" label="MapPartitionsRDD [1124] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2995 { label="Exchange"; 1125 [labelType="html" label="MapPartitionsRDD [1125] save at FileStorageAdapterImpl.java:755"]; } } 1123->1124; 1124->1125; }

digraph G { subgraph clusterstage_436 { label="Stage 436 (skipped)"; subgraph cluster3007 { label="AQEShuffleRead"; 1129 [labelType="html" label="ShuffledRowRDD [1129] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3004 { label="WholeStageCodegen (1)"; 1130 [labelType="html" label="MapPartitionsRDD [1130] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3012 { label="AQEShuffleRead"; 1131 [labelType="html" label="ShuffledRowRDD [1131] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3009 { label="WholeStageCodegen (2)"; 1132 [labelType="html" label="MapPartitionsRDD [1132] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3000 { label="WholeStageCodegen (3)"; 1133 [labelType="html" label="ZippedPartitionsRDD2 [1133] [Unordered] save at FileStorageAdapterImpl.java:755"]; 1134 [labelType="html" label="MapPartitionsRDD [1134] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2999 { label="Exchange"; 1135 [labelType="html" label="MapPartitionsRDD [1135] [Unordered] save at FileStorageAdapterImpl.java:755"]; } } 1129->1130; 1131->1132; 1130->1133; 1132->1133; 1133->1134; 1134->1135; }

1122,1129

1125,1131

digraph G { subgraph clusterstage_437 { label="Stage 437 (skipped)"; subgraph cluster2998 { label="LocalTableScan"; 1126 [labelType="html" label="ParallelCollectionRDD [1126] save at FileStorageAdapterImpl.java:755"]; 1127 [labelType="html" label="MapPartitionsRDD [1127] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster2997 { label="Exchange"; 1128 [labelType="html" label="MapPartitionsRDD [1128] save at FileStorageAdapterImpl.java:755"]; } } 1126->1127; 1127->1128; }

digraph G { subgraph clusterstage_438 { label="Stage 438"; subgraph cluster3022 { label="AQEShuffleRead"; 1136 [labelType="html" label="ShuffledRowRDD [1136] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3019 { label="WholeStageCodegen (4)"; 1137 [labelType="html" label="MapPartitionsRDD [1137] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3027 { label="AQEShuffleRead"; 1138 [labelType="html" label="ShuffledRowRDD [1138] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3024 { label="WholeStageCodegen (5)"; 1139 [labelType="html" label="MapPartitionsRDD [1139] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3014 { label="WholeStageCodegen (6)"; 1140 [labelType="html" label="ZippedPartitionsRDD2 [1140] [Unordered] save at FileStorageAdapterImpl.java:755"]; 1141 [labelType="html" label="MapPartitionsRDD [1141] [Unordered] save at FileStorageAdapterImpl.java:755"]; } subgraph cluster3013 { label="WriteFiles"; 1142 [labelType="html" label="MapPartitionsRDD [1142] [Unordered] save at FileStorageAdapterImpl.java:755"]; } } 1136->1137; 1138->1139; 1137->1140; 1139->1140; 1140->1141; 1141->1142; }

1135,1136

1128,1138

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
438	tenants-pool-286	replenishmentRunId = 10000000096 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = e3aeb3ac-cdab-38d4-8651-88ee8ccad2a4 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.OrderQuantityOptimizationStreamingActivityImpl.prepareStreams(OrderQuantityOptimizationStreamingActivityImpl.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:46	0.3 s	1/1		28.0 KiB	263.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

438

tenants-pool-286

replenishmentRunId = 10000000096 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = e3aeb3ac-cdab-38d4-8651-88ee8ccad2a4 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.OrderQuantityOptimizationStreamingActivityImpl.prepareStreams(OrderQuantityOptimizationStreamingActivityImpl.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:46

0.3 s

1/1

28.0 KiB

263.0 B

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
437	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.OrderQuantityOptimizationStreamingActivityImpl.prepareStreams(OrderQuantityOptimizationStreamingActivityImpl.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
436	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.OrderQuantityOptimizationStreamingActivityImpl.prepareStreams(OrderQuantityOptimizationStreamingActivityImpl.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
435	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.OrderQuantityOptimizationStreamingActivityImpl.prepareStreams(OrderQuantityOptimizationStreamingActivityImpl.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
434	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.OrderQuantityOptimizationStreamingActivityImpl.prepareStreams(OrderQuantityOptimizationStreamingActivityImpl.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

Page: