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

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

Enable zooming

digraph G { id="graph_1271352"; subgraph graph_stage_1271352 { id="graph_stage_1271352"; isCluster="true"; label="Stage 1271352"; subgraph cluster_857674 { id="cluster_857674"; isCluster="true"; label="Scan parquet "; 333427 [id="node_333427" labelType="html" label="FileScanRDD [333427] start at FileStorageAdapterImpl.java:567}"]; 333428 [id="node_333428" labelType="html" label="MapPartitionsRDD [333428] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_857669 { id="cluster_857669"; isCluster="true"; label="WholeStageCodegen (3)"; 333429 [id="node_333429" labelType="html" label="MapPartitionsRDD [333429] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_857668 { id="cluster_857668"; isCluster="true"; label="Exchange"; 333430 [id="node_333430" labelType="html" label="MapPartitionsRDD [333430] start at FileStorageAdapterImpl.java:567}"]; } } 333427->333428; 333428->333429; 333429->333430; }

digraph G { id="graph_1271353"; subgraph graph_stage_1271353 { id="graph_stage_1271353"; isCluster="true"; label="Stage 1271353"; subgraph cluster_857668 { id="cluster_857668"; isCluster="true"; label="Exchange"; 333431 [id="node_333431" labelType="html" label="ShuffledRowRDD [333431] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_857655 { id="cluster_857655"; isCluster="true"; label="WholeStageCodegen (4)"; 333432 [id="node_333432" labelType="html" label="MapPartitionsRDD [333432] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_857654 { id="cluster_857654"; isCluster="true"; label="Exchange"; 333433 [id="node_333433" labelType="html" label="MapPartitionsRDD [333433] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 333431->333432; 333432->333433; }

333430,333431

digraph G { id="graph_1271354"; subgraph graph_stage_1271354 { id="graph_stage_1271354"; isCluster="true"; label="Stage 1271354"; subgraph cluster_857654 { id="cluster_857654"; isCluster="true"; label="Exchange"; 333434 [id="node_333434" labelType="html" label="ShuffledRowRDD [333434] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_857639 { id="cluster_857639"; isCluster="true"; label="WholeStageCodegen (5)"; 333435 [id="node_333435" labelType="html" label="MapPartitionsRDD [333435] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_857638 { id="cluster_857638"; isCluster="true"; label="Exchange"; 333436 [id="node_333436" labelType="html" label="MapPartitionsRDD [333436] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 333434->333435; 333435->333436; }

333433,333434

digraph G { id="graph_1271355"; subgraph graph_stage_1271355 { id="graph_stage_1271355"; isCluster="true"; label="Stage 1271355"; subgraph cluster_857638 { id="cluster_857638"; isCluster="true"; label="Exchange"; 333437 [id="node_333437" labelType="html" label="ShuffledRowRDD [333437] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_857624 { id="cluster_857624"; isCluster="true"; label="WholeStageCodegen (6)"; 333438 [id="node_333438" labelType="html" label="MapPartitionsRDD [333438] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_857675 { id="cluster_857675"; isCluster="true"; label="mapPartitionsInternal"; 333439 [id="node_333439" labelType="html" label="MapPartitionsRDD [333439] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 333437->333438; 333438->333439; }

333436,333437

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
1271355	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 41 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:10:33	0.2 s	30/30
1271354	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 41 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:10:33	0.3 s	30/30
1271353	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 41 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:10:32	0.2 s	30/30
1271352	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 41 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:10:32	0.2 s	6/6

Page: