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

Status: SUCCEEDED
Submitted: 2026/07/22 20:37:18
Duration: 0.4 s
Associated SQL Query: 93797
Job Group: f82340b3-4413-4826-9fdb-37fdaa6940fe
Completed Stages: 4

Enable zooming

digraph G { id="graph_3728002"; subgraph graph_stage_3728002 { id="graph_stage_3728002"; isCluster="true"; label="Stage 3728002"; subgraph cluster_2797681 { id="cluster_2797681"; isCluster="true"; label="Scan parquet "; 1062463 [id="node_1062463" labelType="html" label="FileScanRDD [1062463] start at FileStorageAdapterImpl.java:598}"]; 1062464 [id="node_1062464" labelType="html" label="MapPartitionsRDD [1062464] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797676 { id="cluster_2797676"; isCluster="true"; label="WholeStageCodegen (3)"; 1062465 [id="node_1062465" labelType="html" label="MapPartitionsRDD [1062465] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797675 { id="cluster_2797675"; isCluster="true"; label="Exchange"; 1062466 [id="node_1062466" labelType="html" label="MapPartitionsRDD [1062466] start at FileStorageAdapterImpl.java:598}"]; } } 1062463->1062464; 1062464->1062465; 1062465->1062466; }

digraph G { id="graph_3728003"; subgraph graph_stage_3728003 { id="graph_stage_3728003"; isCluster="true"; label="Stage 3728003"; subgraph cluster_2797675 { id="cluster_2797675"; isCluster="true"; label="Exchange"; 1062467 [id="node_1062467" labelType="html" label="ShuffledRowRDD [1062467] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797668 { id="cluster_2797668"; isCluster="true"; label="WholeStageCodegen (4)"; 1062468 [id="node_1062468" labelType="html" label="MapPartitionsRDD [1062468] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797667 { id="cluster_2797667"; isCluster="true"; label="Exchange"; 1062469 [id="node_1062469" labelType="html" label="MapPartitionsRDD [1062469] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 1062467->1062468; 1062468->1062469; }

1062466,1062467

digraph G { id="graph_3728004"; subgraph graph_stage_3728004 { id="graph_stage_3728004"; isCluster="true"; label="Stage 3728004"; subgraph cluster_2797667 { id="cluster_2797667"; isCluster="true"; label="Exchange"; 1062470 [id="node_1062470" labelType="html" label="ShuffledRowRDD [1062470] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797638 { id="cluster_2797638"; isCluster="true"; label="WholeStageCodegen (5)"; 1062471 [id="node_1062471" labelType="html" label="MapPartitionsRDD [1062471] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797634 { id="cluster_2797634"; isCluster="true"; label="CollectLimit"; 1062472 [id="node_1062472" labelType="html" label="MapPartitionsRDD [1062472] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 1062473 [id="node_1062473" labelType="html" label="MapPartitionsRDD [1062473] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 1062470->1062471; 1062471->1062472; 1062472->1062473; }

1062469,1062470

digraph G { id="graph_3728005"; subgraph graph_stage_3728005 { id="graph_stage_3728005"; isCluster="true"; label="Stage 3728005"; subgraph cluster_2797634 { id="cluster_2797634"; isCluster="true"; label="CollectLimit"; 1062474 [id="node_1062474" labelType="html" label="ShuffledRowRDD [1062474] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 1062475 [id="node_1062475" labelType="html" label="MapPartitionsRDD [1062475] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797682 { id="cluster_2797682"; isCluster="true"; label="mapPartitionsInternal"; 1062476 [id="node_1062476" labelType="html" label="MapPartitionsRDD [1062476] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 1062474->1062475; 1062475->1062476; }

1062473,1062474

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
3728005	tenants-pool-169	stream-10000001452-1 id = d8095b92-94ab-46e0-9c45-70c2545e39e1 runId = f82340b3-4413-4826-9fdb-37fdaa6940fe batch = 69 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/07/22 20:37:18	14 ms	1/1
3728004	tenants-pool-169	stream-10000001452-1 id = d8095b92-94ab-46e0-9c45-70c2545e39e1 runId = f82340b3-4413-4826-9fdb-37fdaa6940fe batch = 69 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/07/22 20:37:18	0.2 s	30/30
3728003	tenants-pool-169	stream-10000001452-1 id = d8095b92-94ab-46e0-9c45-70c2545e39e1 runId = f82340b3-4413-4826-9fdb-37fdaa6940fe batch = 69 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/07/22 20:37:18	27 ms	30/30
3728002	tenants-pool-169	stream-10000001452-1 id = d8095b92-94ab-46e0-9c45-70c2545e39e1 runId = f82340b3-4413-4826-9fdb-37fdaa6940fe batch = 69 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/07/22 20:37:18	0.1 s	17/17

Page: