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

Status: SUCCEEDED
Submitted: 2026/09/01 11:02:49
Duration: 2 s
Associated SQL Query: 33256
Job Group: 98bbba2d-07a7-407d-a16c-88a130d13a5c
Completed Stages: 4

Enable zooming

digraph G { id="graph_896343"; subgraph graph_stage_896343 { id="graph_stage_896343"; isCluster="true"; label="Stage 896343"; 378814 [id="node_378814" labelType="html" label="SQLExecutionRDD [378814] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_949575 { id="cluster_949575"; isCluster="true"; label="Scan parquet "; 378811 [id="node_378811" labelType="html" label="FileScanRDD [378811] start at FileStorageAdapterImpl.java:596}"]; 378812 [id="node_378812" labelType="html" label="MapPartitionsRDD [378812] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_949572 { id="cluster_949572"; isCluster="true"; label="WholeStageCodegen (1)"; 378813 [id="node_378813" labelType="html" label="MapPartitionsRDD [378813] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_949590 { id="cluster_949590"; isCluster="true"; label="WholeStageCodegen (1)"; 378815 [id="node_378815" labelType="html" label="MapPartitionsRDD [378815] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_949589 { id="cluster_949589"; isCluster="true"; label="HashAggregate"; 378816 [id="node_378816" labelType="html" label="MapPartitionsRDD [378816] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_949588 { id="cluster_949588"; isCluster="true"; label="Exchange"; 378817 [id="node_378817" labelType="html" label="MapPartitionsRDD [378817] start at FileStorageAdapterImpl.java:596}"]; } } 378811->378812; 378812->378813; 378813->378814; 378814->378815; 378815->378816; 378816->378817; }

digraph G { id="graph_896344"; subgraph graph_stage_896344 { id="graph_stage_896344"; isCluster="true"; label="Stage 896344"; subgraph cluster_949588 { id="cluster_949588"; isCluster="true"; label="Exchange"; 378818 [id="node_378818" labelType="html" label="ShuffledRowRDD [378818] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_949585 { id="cluster_949585"; isCluster="true"; label="WholeStageCodegen (2)"; 378819 [id="node_378819" labelType="html" label="MapPartitionsRDD [378819] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_949584 { id="cluster_949584"; isCluster="true"; label="Exchange"; 378820 [id="node_378820" labelType="html" label="MapPartitionsRDD [378820] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 378818->378819; 378819->378820; }

378817,378818

digraph G { id="graph_896345"; subgraph graph_stage_896345 { id="graph_stage_896345"; isCluster="true"; label="Stage 896345"; subgraph cluster_949584 { id="cluster_949584"; isCluster="true"; label="Exchange"; 378821 [id="node_378821" labelType="html" label="ShuffledRowRDD [378821] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_949583 { id="cluster_949583"; isCluster="true"; label="InMemoryTableScan"; 378822 [id="node_378822" labelType="html" label="MapPartitionsRDD [378822] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 378823 [id="node_378823" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#8912052L, 30), REPARTITION_BY_NUM, [plan_id=2646195]\n+- *(2) HashAggregate(keys=[demandChannel#8912055, shardId#8912051, kpis#8912057, version#8912053, qty#8912054, worklistShardItemId#8912052L, demandStream#8912056], functions=[], output=[shardId#8912051, worklistShardItemId#8912052L, version#8912053, qty#8912054, demandChannel#8912055, demandStream#8912056, kpis#8912057])\n +- Exchange hashpartitioning(demandChannel#8912055, shardId#8912051, kpis#8912057, version#8912053, qty#8912054, worklistShardItemId#8912052L, demandStream#8912056, 30), ENSURE_REQUIREMENTS, [plan_id=2646191]\n +- HashAggregate(keys=[demandChannel#8912055, shardId#8912051, knownfloatingpointnormalized(transform(kpis#8912057, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#8912144)) null else named_struct(label, lambda arg#8912144.label, dateTime, lambda arg#8912144.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#8912144.value)))), lambda ... [378823] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 378824 [id="node_378824" labelType="html" label="MapPartitionsRDD [378824] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 378825 [id="node_378825" labelType="html" label="MapPartitionsRDD [378825] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 378826 [id="node_378826" labelType="html" label="MapPartitionsRDD [378826] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_949580 { id="cluster_949580"; isCluster="true"; label="WholeStageCodegen (1)"; 378827 [id="node_378827" labelType="html" label="MapPartitionsRDD [378827] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_949579 { id="cluster_949579"; isCluster="true"; label="Exchange"; 378828 [id="node_378828" labelType="html" label="MapPartitionsRDD [378828] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 378821->378822; 378822->378823; 378823->378824; 378824->378825; 378825->378826; 378826->378827; 378827->378828; }

378820,378821

378823

digraph G { id="graph_896346"; subgraph graph_stage_896346 { id="graph_stage_896346"; isCluster="true"; label="Stage 896346"; subgraph cluster_949579 { id="cluster_949579"; isCluster="true"; label="Exchange"; 378829 [id="node_378829" labelType="html" label="ShuffledRowRDD [378829] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_949576 { id="cluster_949576"; isCluster="true"; label="WholeStageCodegen (2)"; 378830 [id="node_378830" labelType="html" label="MapPartitionsRDD [378830] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_949592 { id="cluster_949592"; isCluster="true"; label="mapPartitionsInternal"; 378831 [id="node_378831" labelType="html" label="MapPartitionsRDD [378831] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 378829->378830; 378830->378831; }

378828,378829

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
896346	tenants-pool-506	stream-10000000538-1 id = 6a5f8344-c315-4fb0-b9ab-ad03d279ced3 runId = 98bbba2d-07a7-407d-a16c-88a130d13a5c batch = 14 start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/09/01 11:02:51	0.1 s	30/30	2.8 KiB
896345	tenants-pool-506	stream-10000000538-1 id = 6a5f8344-c315-4fb0-b9ab-ad03d279ced3 runId = 98bbba2d-07a7-407d-a16c-88a130d13a5c batch = 14 start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/09/01 11:02:50	0.7 s	30/30	3.0 MiB	2.8 KiB
896344	tenants-pool-506	stream-10000000538-1 id = 6a5f8344-c315-4fb0-b9ab-ad03d279ced3 runId = 98bbba2d-07a7-407d-a16c-88a130d13a5c batch = 14 start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/09/01 11:02:50	0.3 s	30/30	3.0 MiB	3.0 MiB
896343	tenants-pool-506	stream-10000000538-1 id = 6a5f8344-c315-4fb0-b9ab-ad03d279ced3 runId = 98bbba2d-07a7-407d-a16c-88a130d13a5c batch = 14 start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/09/01 11:02:49	1 s	30/30		3.0 MiB

Page: