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

Status: SUCCEEDED
Submitted: 2026/09/02 14:12:01
Duration: 4 s
Associated SQL Query: 62280
Job Group: d8ab24cc-742c-44e6-9e5e-19e910f59f22
Completed Stages: 4

Enable zooming

digraph G { id="graph_1656094"; subgraph graph_stage_1656094 { id="graph_stage_1656094"; isCluster="true"; label="Stage 1656094"; 709725 [id="node_709725" labelType="html" label="SQLExecutionRDD [709725] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1779366 { id="cluster_1779366"; isCluster="true"; label="Scan parquet "; 709722 [id="node_709722" labelType="html" label="FileScanRDD [709722] start at FileStorageAdapterImpl.java:596}"]; 709723 [id="node_709723" labelType="html" label="MapPartitionsRDD [709723] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779363 { id="cluster_1779363"; isCluster="true"; label="WholeStageCodegen (1)"; 709724 [id="node_709724" labelType="html" label="MapPartitionsRDD [709724] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779381 { id="cluster_1779381"; isCluster="true"; label="WholeStageCodegen (1)"; 709726 [id="node_709726" labelType="html" label="MapPartitionsRDD [709726] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779380 { id="cluster_1779380"; isCluster="true"; label="HashAggregate"; 709727 [id="node_709727" labelType="html" label="MapPartitionsRDD [709727] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779379 { id="cluster_1779379"; isCluster="true"; label="Exchange"; 709728 [id="node_709728" labelType="html" label="MapPartitionsRDD [709728] start at FileStorageAdapterImpl.java:596}"]; } } 709722->709723; 709723->709724; 709724->709725; 709725->709726; 709726->709727; 709727->709728; }

digraph G { id="graph_1656095"; subgraph graph_stage_1656095 { id="graph_stage_1656095"; isCluster="true"; label="Stage 1656095"; subgraph cluster_1779379 { id="cluster_1779379"; isCluster="true"; label="Exchange"; 709729 [id="node_709729" labelType="html" label="ShuffledRowRDD [709729] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779376 { id="cluster_1779376"; isCluster="true"; label="WholeStageCodegen (2)"; 709730 [id="node_709730" labelType="html" label="MapPartitionsRDD [709730] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779375 { id="cluster_1779375"; isCluster="true"; label="Exchange"; 709731 [id="node_709731" labelType="html" label="MapPartitionsRDD [709731] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 709729->709730; 709730->709731; }

709728,709729

digraph G { id="graph_1656096"; subgraph graph_stage_1656096 { id="graph_stage_1656096"; isCluster="true"; label="Stage 1656096"; subgraph cluster_1779375 { id="cluster_1779375"; isCluster="true"; label="Exchange"; 709732 [id="node_709732" labelType="html" label="ShuffledRowRDD [709732] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779374 { id="cluster_1779374"; isCluster="true"; label="InMemoryTableScan"; 709733 [id="node_709733" labelType="html" label="MapPartitionsRDD [709733] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709734 [id="node_709734" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#16691990L, 30), REPARTITION_BY_NUM, [plan_id=4962697]\n+- *(2) HashAggregate(keys=[demandChannel#16691993, shardId#16691989, kpis#16691995, version#16691991, qty#16691992, worklistShardItemId#16691990L, demandStream#16691994], functions=[], output=[shardId#16691989, worklistShardItemId#16691990L, version#16691991, qty#16691992, demandChannel#16691993, demandStream#16691994, kpis#16691995])\n +- Exchange hashpartitioning(demandChannel#16691993, shardId#16691989, kpis#16691995, version#16691991, qty#16691992, worklistShardItemId#16691990L, demandStream#16691994, 30), ENSURE_REQUIREMENTS, [plan_id=4962693]\n +- HashAggregate(keys=[demandChannel#16691993, shardId#16691989, knownfloatingpointnormalized(transform(kpis#16691995, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#16692082)) null else named_struct(label, lambda arg#16692082.label, dateTime, lambda arg#16692082.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [709734] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709735 [id="node_709735" labelType="html" label="MapPartitionsRDD [709735] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709736 [id="node_709736" labelType="html" label="MapPartitionsRDD [709736] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709737 [id="node_709737" labelType="html" label="MapPartitionsRDD [709737] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779371 { id="cluster_1779371"; isCluster="true"; label="WholeStageCodegen (1)"; 709738 [id="node_709738" labelType="html" label="MapPartitionsRDD [709738] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779370 { id="cluster_1779370"; isCluster="true"; label="Exchange"; 709739 [id="node_709739" labelType="html" label="MapPartitionsRDD [709739] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 709732->709733; 709733->709734; 709734->709735; 709735->709736; 709736->709737; 709737->709738; 709738->709739; }

709731,709732

709734

digraph G { id="graph_1656097"; subgraph graph_stage_1656097 { id="graph_stage_1656097"; isCluster="true"; label="Stage 1656097"; subgraph cluster_1779370 { id="cluster_1779370"; isCluster="true"; label="Exchange"; 709740 [id="node_709740" labelType="html" label="ShuffledRowRDD [709740] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779367 { id="cluster_1779367"; isCluster="true"; label="WholeStageCodegen (2)"; 709741 [id="node_709741" labelType="html" label="MapPartitionsRDD [709741] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779383 { id="cluster_1779383"; isCluster="true"; label="mapPartitionsInternal"; 709742 [id="node_709742" labelType="html" label="MapPartitionsRDD [709742] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 709740->709741; 709741->709742; }

709739,709740

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1656097	tenants-pool-506	stream-10000000548-2 id = e6c89ecb-41f0-4c0d-a2b7-5cd5af2cdfb7 runId = d8ab24cc-742c-44e6-9e5e-19e910f59f22 batch = 38 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/02 14:12:05	0.1 s	30/30	2.8 KiB
1656096	tenants-pool-506	stream-10000000548-2 id = e6c89ecb-41f0-4c0d-a2b7-5cd5af2cdfb7 runId = d8ab24cc-742c-44e6-9e5e-19e910f59f22 batch = 38 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/02 14:12:04	1.0 s	30/30	13.8 MiB	2.8 KiB
1656095	tenants-pool-506	stream-10000000548-2 id = e6c89ecb-41f0-4c0d-a2b7-5cd5af2cdfb7 runId = d8ab24cc-742c-44e6-9e5e-19e910f59f22 batch = 38 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/02 14:12:04	0.5 s	30/30	13.6 MiB	13.8 MiB
1656094	tenants-pool-506	stream-10000000548-2 id = e6c89ecb-41f0-4c0d-a2b7-5cd5af2cdfb7 runId = d8ab24cc-742c-44e6-9e5e-19e910f59f22 batch = 38 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/02 14:12:01	3 s	30/30		13.6 MiB

Page: