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

Status: SUCCEEDED
Submitted: 2026/07/22 02:22:24
Duration: 0.8 s
Associated SQL Query: 41338
Job Group: 8fdff9a8-5e79-4dc5-83bf-49d519329d02
Completed Stages: 4

Enable zooming

digraph G { id="graph_1576018"; subgraph graph_stage_1576018 { id="graph_stage_1576018"; isCluster="true"; label="Stage 1576018"; subgraph cluster_1233424 { id="cluster_1233424"; isCluster="true"; label="Scan parquet "; 468032 [id="node_468032" labelType="html" label="FileScanRDD [468032] start at FileStorageAdapterImpl.java:598}"]; 468033 [id="node_468033" labelType="html" label="MapPartitionsRDD [468033] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1233419 { id="cluster_1233419"; isCluster="true"; label="WholeStageCodegen (3)"; 468034 [id="node_468034" labelType="html" label="MapPartitionsRDD [468034] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1233418 { id="cluster_1233418"; isCluster="true"; label="Exchange"; 468035 [id="node_468035" labelType="html" label="MapPartitionsRDD [468035] start at FileStorageAdapterImpl.java:598}"]; } } 468032->468033; 468033->468034; 468034->468035; }

digraph G { id="graph_1576019"; subgraph graph_stage_1576019 { id="graph_stage_1576019"; isCluster="true"; label="Stage 1576019"; subgraph cluster_1233418 { id="cluster_1233418"; isCluster="true"; label="Exchange"; 468036 [id="node_468036" labelType="html" label="ShuffledRowRDD [468036] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1233411 { id="cluster_1233411"; isCluster="true"; label="WholeStageCodegen (4)"; 468037 [id="node_468037" labelType="html" label="MapPartitionsRDD [468037] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1233410 { id="cluster_1233410"; isCluster="true"; label="Exchange"; 468038 [id="node_468038" labelType="html" label="MapPartitionsRDD [468038] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 468036->468037; 468037->468038; }

468035,468036

digraph G { id="graph_1576020"; subgraph graph_stage_1576020 { id="graph_stage_1576020"; isCluster="true"; label="Stage 1576020"; subgraph cluster_1233410 { id="cluster_1233410"; isCluster="true"; label="Exchange"; 468039 [id="node_468039" labelType="html" label="ShuffledRowRDD [468039] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1233389 { id="cluster_1233389"; isCluster="true"; label="WholeStageCodegen (5)"; 468040 [id="node_468040" labelType="html" label="MapPartitionsRDD [468040] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1233388 { id="cluster_1233388"; isCluster="true"; label="Exchange"; 468041 [id="node_468041" labelType="html" label="MapPartitionsRDD [468041] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 468039->468040; 468040->468041; }

468038,468039

digraph G { id="graph_1576021"; subgraph graph_stage_1576021 { id="graph_stage_1576021"; isCluster="true"; label="Stage 1576021"; subgraph cluster_1233388 { id="cluster_1233388"; isCluster="true"; label="Exchange"; 468042 [id="node_468042" labelType="html" label="ShuffledRowRDD [468042] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1233374 { id="cluster_1233374"; isCluster="true"; label="WholeStageCodegen (6)"; 468043 [id="node_468043" labelType="html" label="MapPartitionsRDD [468043] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1233425 { id="cluster_1233425"; isCluster="true"; label="mapPartitionsInternal"; 468044 [id="node_468044" labelType="html" label="MapPartitionsRDD [468044] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 468042->468043; 468043->468044; }

468041,468042

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
1576021	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 50 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 02:22:25	0.2 s	30/30
1576020	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 50 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 02:22:24	0.2 s	30/30
1576019	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 50 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 02:22:24	0.2 s	30/30
1576018	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 50 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 02:22:24	0.2 s	37/37

Page: