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

Status: SUCCEEDED
Submitted: 2026/05/22 09:01:32
Duration: 1 s
Associated SQL Query: 24293
Job Group: 10d36e12-5b96-4752-9e6b-ca062fdd8807
Completed Stages: 4

Enable zooming

digraph G { id="graph_1252130"; subgraph graph_stage_1252130 { id="graph_stage_1252130"; isCluster="true"; label="Stage 1252130"; subgraph cluster_847829 { id="cluster_847829"; isCluster="true"; label="Scan parquet "; 329545 [id="node_329545" labelType="html" label="FileScanRDD [329545] start at FileStorageAdapterImpl.java:567}"]; 329546 [id="node_329546" labelType="html" label="MapPartitionsRDD [329546] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_847824 { id="cluster_847824"; isCluster="true"; label="WholeStageCodegen (3)"; 329547 [id="node_329547" labelType="html" label="MapPartitionsRDD [329547] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_847823 { id="cluster_847823"; isCluster="true"; label="Exchange"; 329548 [id="node_329548" labelType="html" label="MapPartitionsRDD [329548] start at FileStorageAdapterImpl.java:567}"]; } } 329545->329546; 329546->329547; 329547->329548; }

digraph G { id="graph_1252131"; subgraph graph_stage_1252131 { id="graph_stage_1252131"; isCluster="true"; label="Stage 1252131"; subgraph cluster_847823 { id="cluster_847823"; isCluster="true"; label="Exchange"; 329549 [id="node_329549" labelType="html" label="ShuffledRowRDD [329549] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_847810 { id="cluster_847810"; isCluster="true"; label="WholeStageCodegen (4)"; 329550 [id="node_329550" labelType="html" label="MapPartitionsRDD [329550] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_847809 { id="cluster_847809"; isCluster="true"; label="Exchange"; 329551 [id="node_329551" labelType="html" label="MapPartitionsRDD [329551] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 329549->329550; 329550->329551; }

329548,329549

digraph G { id="graph_1252132"; subgraph graph_stage_1252132 { id="graph_stage_1252132"; isCluster="true"; label="Stage 1252132"; subgraph cluster_847809 { id="cluster_847809"; isCluster="true"; label="Exchange"; 329552 [id="node_329552" labelType="html" label="ShuffledRowRDD [329552] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_847794 { id="cluster_847794"; isCluster="true"; label="WholeStageCodegen (5)"; 329553 [id="node_329553" labelType="html" label="MapPartitionsRDD [329553] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_847793 { id="cluster_847793"; isCluster="true"; label="Exchange"; 329554 [id="node_329554" labelType="html" label="MapPartitionsRDD [329554] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 329552->329553; 329553->329554; }

329551,329552

digraph G { id="graph_1252133"; subgraph graph_stage_1252133 { id="graph_stage_1252133"; isCluster="true"; label="Stage 1252133"; subgraph cluster_847793 { id="cluster_847793"; isCluster="true"; label="Exchange"; 329555 [id="node_329555" labelType="html" label="ShuffledRowRDD [329555] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_847779 { id="cluster_847779"; isCluster="true"; label="WholeStageCodegen (6)"; 329556 [id="node_329556" labelType="html" label="MapPartitionsRDD [329556] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_847830 { id="cluster_847830"; isCluster="true"; label="mapPartitionsInternal"; 329557 [id="node_329557" labelType="html" label="MapPartitionsRDD [329557] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 329555->329556; 329556->329557; }

329554,329555

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1252133	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 32 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:01:33	0.2 s	30/30
1252132	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 32 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:01:33	0.3 s	30/30	450.0 B
1252131	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 32 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:01:33	0.2 s	30/30	504.0 B	450.0 B
1252130	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 32 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:01:32	0.3 s	25/25		504.0 B

Page: