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

Status: SUCCEEDED
Submitted: 2026/08/31 14:22:03
Duration: 3 s
Associated SQL Query: 13514
Job Group: 688c595e-a841-4933-aa02-353eb721dac8
Completed Stages: 4

Enable zooming

digraph G { id="graph_341134"; subgraph graph_stage_341134 { id="graph_stage_341134"; isCluster="true"; label="Stage 341134"; 154061 [id="node_154061" labelType="html" label="SQLExecutionRDD [154061] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_385367 { id="cluster_385367"; isCluster="true"; label="Scan parquet "; 154058 [id="node_154058" labelType="html" label="FileScanRDD [154058] start at FileStorageAdapterImpl.java:596}"]; 154059 [id="node_154059" labelType="html" label="MapPartitionsRDD [154059] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385364 { id="cluster_385364"; isCluster="true"; label="WholeStageCodegen (1)"; 154060 [id="node_154060" labelType="html" label="MapPartitionsRDD [154060] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385382 { id="cluster_385382"; isCluster="true"; label="WholeStageCodegen (1)"; 154062 [id="node_154062" labelType="html" label="MapPartitionsRDD [154062] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385381 { id="cluster_385381"; isCluster="true"; label="HashAggregate"; 154063 [id="node_154063" labelType="html" label="MapPartitionsRDD [154063] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385380 { id="cluster_385380"; isCluster="true"; label="Exchange"; 154064 [id="node_154064" labelType="html" label="MapPartitionsRDD [154064] start at FileStorageAdapterImpl.java:596}"]; } } 154058->154059; 154059->154060; 154060->154061; 154061->154062; 154062->154063; 154063->154064; }

digraph G { id="graph_341135"; subgraph graph_stage_341135 { id="graph_stage_341135"; isCluster="true"; label="Stage 341135"; subgraph cluster_385380 { id="cluster_385380"; isCluster="true"; label="Exchange"; 154065 [id="node_154065" labelType="html" label="ShuffledRowRDD [154065] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385377 { id="cluster_385377"; isCluster="true"; label="WholeStageCodegen (2)"; 154066 [id="node_154066" labelType="html" label="MapPartitionsRDD [154066] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385376 { id="cluster_385376"; isCluster="true"; label="Exchange"; 154067 [id="node_154067" labelType="html" label="MapPartitionsRDD [154067] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154065->154066; 154066->154067; }

154064,154065

digraph G { id="graph_341136"; subgraph graph_stage_341136 { id="graph_stage_341136"; isCluster="true"; label="Stage 341136"; subgraph cluster_385376 { id="cluster_385376"; isCluster="true"; label="Exchange"; 154068 [id="node_154068" labelType="html" label="ShuffledRowRDD [154068] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385375 { id="cluster_385375"; isCluster="true"; label="InMemoryTableScan"; 154069 [id="node_154069" labelType="html" label="MapPartitionsRDD [154069] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154070 [id="node_154070" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3614482L, 30), REPARTITION_BY_NUM, [plan_id=1034625]\n+- *(2) HashAggregate(keys=[demandChannel#3614485, shardId#3614481, kpis#3614487, version#3614483, qty#3614484, worklistShardItemId#3614482L, demandStream#3614486], functions=[], output=[shardId#3614481, worklistShardItemId#3614482L, version#3614483, qty#3614484, demandChannel#3614485, demandStream#3614486, kpis#3614487])\n +- Exchange hashpartitioning(demandChannel#3614485, shardId#3614481, kpis#3614487, version#3614483, qty#3614484, worklistShardItemId#3614482L, demandStream#3614486, 30), ENSURE_REQUIREMENTS, [plan_id=1034621]\n +- HashAggregate(keys=[demandChannel#3614485, shardId#3614481, knownfloatingpointnormalized(transform(kpis#3614487, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3614581)) null else named_struct(label, lambda arg#3614581.label, dateTime, lambda arg#3614581.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3614581.value)))), lambda ... [154070] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154071 [id="node_154071" labelType="html" label="MapPartitionsRDD [154071] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154072 [id="node_154072" labelType="html" label="MapPartitionsRDD [154072] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154073 [id="node_154073" labelType="html" label="MapPartitionsRDD [154073] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385372 { id="cluster_385372"; isCluster="true"; label="WholeStageCodegen (1)"; 154074 [id="node_154074" labelType="html" label="MapPartitionsRDD [154074] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385371 { id="cluster_385371"; isCluster="true"; label="Exchange"; 154075 [id="node_154075" labelType="html" label="MapPartitionsRDD [154075] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154068->154069; 154069->154070; 154070->154071; 154071->154072; 154072->154073; 154073->154074; 154074->154075; }

154067,154068

154070

digraph G { id="graph_341137"; subgraph graph_stage_341137 { id="graph_stage_341137"; isCluster="true"; label="Stage 341137"; subgraph cluster_385371 { id="cluster_385371"; isCluster="true"; label="Exchange"; 154076 [id="node_154076" labelType="html" label="ShuffledRowRDD [154076] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385368 { id="cluster_385368"; isCluster="true"; label="WholeStageCodegen (2)"; 154077 [id="node_154077" labelType="html" label="MapPartitionsRDD [154077] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385384 { id="cluster_385384"; isCluster="true"; label="mapPartitionsInternal"; 154078 [id="node_154078" labelType="html" label="MapPartitionsRDD [154078] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154076->154077; 154077->154078; }

154075,154076

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
341137	tenants-pool-506	stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 688c595e-a841-4933-aa02-353eb721dac8 batch = 20 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/08/31 14:22:05	0.5 s	30/30	2.8 KiB
341136	tenants-pool-506	stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 688c595e-a841-4933-aa02-353eb721dac8 batch = 20 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/08/31 14:22:05	0.4 s	30/30	5.5 MiB	2.8 KiB
341135	tenants-pool-506	stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 688c595e-a841-4933-aa02-353eb721dac8 batch = 20 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/08/31 14:22:04	0.3 s	30/30	5.6 MiB	5.5 MiB
341134	tenants-pool-506	stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 688c595e-a841-4933-aa02-353eb721dac8 batch = 20 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/08/31 14:22:03	1 s	30/30		5.6 MiB

Page: