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

Status: SUCCEEDED
Submitted: 2026/05/22 09:08:35
Duration: 0.5 s
Associated SQL Query: 24511
Job Group: 10d36e12-5b96-4752-9e6b-ca062fdd8807
Completed Stages: 4

Enable zooming

digraph G { id="graph_1266459"; subgraph graph_stage_1266459 { id="graph_stage_1266459"; isCluster="true"; label="Stage 1266459"; subgraph cluster_855132 { id="cluster_855132"; isCluster="true"; label="Scan parquet "; 332420 [id="node_332420" labelType="html" label="FileScanRDD [332420] start at FileStorageAdapterImpl.java:567}"]; 332421 [id="node_332421" labelType="html" label="MapPartitionsRDD [332421] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_855127 { id="cluster_855127"; isCluster="true"; label="WholeStageCodegen (3)"; 332422 [id="node_332422" labelType="html" label="MapPartitionsRDD [332422] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_855126 { id="cluster_855126"; isCluster="true"; label="Exchange"; 332423 [id="node_332423" labelType="html" label="MapPartitionsRDD [332423] start at FileStorageAdapterImpl.java:567}"]; } } 332420->332421; 332421->332422; 332422->332423; }

digraph G { id="graph_1266460"; subgraph graph_stage_1266460 { id="graph_stage_1266460"; isCluster="true"; label="Stage 1266460"; subgraph cluster_855126 { id="cluster_855126"; isCluster="true"; label="Exchange"; 332424 [id="node_332424" labelType="html" label="ShuffledRowRDD [332424] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_855119 { id="cluster_855119"; isCluster="true"; label="WholeStageCodegen (4)"; 332425 [id="node_332425" labelType="html" label="MapPartitionsRDD [332425] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_855118 { id="cluster_855118"; isCluster="true"; label="Exchange"; 332426 [id="node_332426" labelType="html" label="MapPartitionsRDD [332426] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 332424->332425; 332425->332426; }

332423,332424

digraph G { id="graph_1266461"; subgraph graph_stage_1266461 { id="graph_stage_1266461"; isCluster="true"; label="Stage 1266461"; subgraph cluster_855118 { id="cluster_855118"; isCluster="true"; label="Exchange"; 332427 [id="node_332427" labelType="html" label="ShuffledRowRDD [332427] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_855089 { id="cluster_855089"; isCluster="true"; label="WholeStageCodegen (5)"; 332428 [id="node_332428" labelType="html" label="MapPartitionsRDD [332428] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_855085 { id="cluster_855085"; isCluster="true"; label="CollectLimit"; 332429 [id="node_332429" labelType="html" label="MapPartitionsRDD [332429] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 332430 [id="node_332430" labelType="html" label="MapPartitionsRDD [332430] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 332427->332428; 332428->332429; 332429->332430; }

332426,332427

digraph G { id="graph_1266462"; subgraph graph_stage_1266462 { id="graph_stage_1266462"; isCluster="true"; label="Stage 1266462"; subgraph cluster_855085 { id="cluster_855085"; isCluster="true"; label="CollectLimit"; 332431 [id="node_332431" labelType="html" label="ShuffledRowRDD [332431] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 332432 [id="node_332432" labelType="html" label="MapPartitionsRDD [332432] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_855133 { id="cluster_855133"; isCluster="true"; label="mapPartitionsInternal"; 332433 [id="node_332433" labelType="html" label="MapPartitionsRDD [332433] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 332431->332432; 332432->332433; }

332430,332431

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
1266462	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 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:08:36	13 ms	1/1
1266461	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 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:08:36	0.2 s	30/30
1266460	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 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:08:36	31 ms	30/30
1266459	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 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:08:35	0.2 s	25/25

Page: