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

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

Enable zooming

digraph G { id="graph_3727652"; subgraph graph_stage_3727652 { id="graph_stage_3727652"; isCluster="true"; label="Stage 3727652"; subgraph cluster_2797569 { id="cluster_2797569"; isCluster="true"; label="Scan parquet "; 1062418 [id="node_1062418" labelType="html" label="FileScanRDD [1062418] start at FileStorageAdapterImpl.java:598}"]; 1062419 [id="node_1062419" labelType="html" label="MapPartitionsRDD [1062419] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797564 { id="cluster_2797564"; isCluster="true"; label="WholeStageCodegen (3)"; 1062420 [id="node_1062420" labelType="html" label="MapPartitionsRDD [1062420] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797563 { id="cluster_2797563"; isCluster="true"; label="Exchange"; 1062421 [id="node_1062421" labelType="html" label="MapPartitionsRDD [1062421] start at FileStorageAdapterImpl.java:598}"]; } } 1062418->1062419; 1062419->1062420; 1062420->1062421; }

digraph G { id="graph_3727653"; subgraph graph_stage_3727653 { id="graph_stage_3727653"; isCluster="true"; label="Stage 3727653"; subgraph cluster_2797563 { id="cluster_2797563"; isCluster="true"; label="Exchange"; 1062422 [id="node_1062422" labelType="html" label="ShuffledRowRDD [1062422] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797550 { id="cluster_2797550"; isCluster="true"; label="WholeStageCodegen (4)"; 1062423 [id="node_1062423" labelType="html" label="MapPartitionsRDD [1062423] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797549 { id="cluster_2797549"; isCluster="true"; label="Exchange"; 1062424 [id="node_1062424" labelType="html" label="MapPartitionsRDD [1062424] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 1062422->1062423; 1062423->1062424; }

1062421,1062422

digraph G { id="graph_3727654"; subgraph graph_stage_3727654 { id="graph_stage_3727654"; isCluster="true"; label="Stage 3727654"; subgraph cluster_2797549 { id="cluster_2797549"; isCluster="true"; label="Exchange"; 1062425 [id="node_1062425" labelType="html" label="ShuffledRowRDD [1062425] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797534 { id="cluster_2797534"; isCluster="true"; label="WholeStageCodegen (5)"; 1062426 [id="node_1062426" labelType="html" label="MapPartitionsRDD [1062426] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797533 { id="cluster_2797533"; isCluster="true"; label="Exchange"; 1062427 [id="node_1062427" labelType="html" label="MapPartitionsRDD [1062427] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 1062425->1062426; 1062426->1062427; }

1062424,1062425

digraph G { id="graph_3727655"; subgraph graph_stage_3727655 { id="graph_stage_3727655"; isCluster="true"; label="Stage 3727655"; subgraph cluster_2797533 { id="cluster_2797533"; isCluster="true"; label="Exchange"; 1062428 [id="node_1062428" labelType="html" label="ShuffledRowRDD [1062428] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797519 { id="cluster_2797519"; isCluster="true"; label="WholeStageCodegen (6)"; 1062429 [id="node_1062429" labelType="html" label="MapPartitionsRDD [1062429] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797570 { id="cluster_2797570"; isCluster="true"; label="mapPartitionsInternal"; 1062430 [id="node_1062430" labelType="html" label="MapPartitionsRDD [1062430] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 1062428->1062429; 1062429->1062430; }

1062427,1062428

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
3727655	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:11	0.2 s	30/30
3727654	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:11	0.3 s	30/30
3727653	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:11	0.2 s	30/30
3727652	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:10	0.2 s	17/17

Page: