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

Status: SUCCEEDED
Submitted: 2026/05/22 09:55:09
Duration: 1 s
Associated SQL Query: 25743
Job Group: 65cb8160-40af-4a1d-9ef7-845fbd048abf
Completed Stages: 4

Enable zooming

digraph G { id="graph_1333830"; subgraph graph_stage_1333830 { id="graph_stage_1333830"; isCluster="true"; label="Stage 1333830"; subgraph cluster_896276 { id="cluster_896276"; isCluster="true"; label="Scan parquet "; 348408 [id="node_348408" labelType="html" label="FileScanRDD [348408] start at FileStorageAdapterImpl.java:567}"]; 348409 [id="node_348409" labelType="html" label="MapPartitionsRDD [348409] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_896271 { id="cluster_896271"; isCluster="true"; label="WholeStageCodegen (3)"; 348410 [id="node_348410" labelType="html" label="MapPartitionsRDD [348410] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_896270 { id="cluster_896270"; isCluster="true"; label="Exchange"; 348411 [id="node_348411" labelType="html" label="MapPartitionsRDD [348411] start at FileStorageAdapterImpl.java:567}"]; } } 348408->348409; 348409->348410; 348410->348411; }

digraph G { id="graph_1333831"; subgraph graph_stage_1333831 { id="graph_stage_1333831"; isCluster="true"; label="Stage 1333831"; subgraph cluster_896270 { id="cluster_896270"; isCluster="true"; label="Exchange"; 348412 [id="node_348412" labelType="html" label="ShuffledRowRDD [348412] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_896257 { id="cluster_896257"; isCluster="true"; label="WholeStageCodegen (4)"; 348413 [id="node_348413" labelType="html" label="MapPartitionsRDD [348413] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_896256 { id="cluster_896256"; isCluster="true"; label="Exchange"; 348414 [id="node_348414" labelType="html" label="MapPartitionsRDD [348414] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 348412->348413; 348413->348414; }

348411,348412

digraph G { id="graph_1333832"; subgraph graph_stage_1333832 { id="graph_stage_1333832"; isCluster="true"; label="Stage 1333832"; subgraph cluster_896256 { id="cluster_896256"; isCluster="true"; label="Exchange"; 348415 [id="node_348415" labelType="html" label="ShuffledRowRDD [348415] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_896241 { id="cluster_896241"; isCluster="true"; label="WholeStageCodegen (5)"; 348416 [id="node_348416" labelType="html" label="MapPartitionsRDD [348416] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_896240 { id="cluster_896240"; isCluster="true"; label="Exchange"; 348417 [id="node_348417" labelType="html" label="MapPartitionsRDD [348417] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 348415->348416; 348416->348417; }

348414,348415

digraph G { id="graph_1333833"; subgraph graph_stage_1333833 { id="graph_stage_1333833"; isCluster="true"; label="Stage 1333833"; subgraph cluster_896240 { id="cluster_896240"; isCluster="true"; label="Exchange"; 348418 [id="node_348418" labelType="html" label="ShuffledRowRDD [348418] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_896226 { id="cluster_896226"; isCluster="true"; label="WholeStageCodegen (6)"; 348419 [id="node_348419" labelType="html" label="MapPartitionsRDD [348419] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_896277 { id="cluster_896277"; isCluster="true"; label="mapPartitionsInternal"; 348420 [id="node_348420" labelType="html" label="MapPartitionsRDD [348420] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 348418->348419; 348419->348420; }

348417,348418

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1333833	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 39 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:55:10	0.2 s	30/30
1333832	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 39 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:55:10	0.3 s	30/30	450.0 B
1333831	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 39 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:55:10	0.3 s	30/30	672.0 B	450.0 B
1333830	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 39 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:55:09	0.3 s	8/8		672.0 B

Page: