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

Status: SUCCEEDED
Submitted: 2026/09/01 14:15:10
Duration: 3 s
Associated SQL Query: 38113
Job Group: 1ebd557e-9283-4610-a07b-41d13bb785c5
Completed Stages: 4

Enable zooming

digraph G { id="graph_1032496"; subgraph graph_stage_1032496 { id="graph_stage_1032496"; isCluster="true"; label="Stage 1032496"; 434067 [id="node_434067" labelType="html" label="SQLExecutionRDD [434067] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1087491 { id="cluster_1087491"; isCluster="true"; label="Scan parquet "; 434064 [id="node_434064" labelType="html" label="FileScanRDD [434064] start at FileStorageAdapterImpl.java:596}"]; 434065 [id="node_434065" labelType="html" label="MapPartitionsRDD [434065] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087488 { id="cluster_1087488"; isCluster="true"; label="WholeStageCodegen (1)"; 434066 [id="node_434066" labelType="html" label="MapPartitionsRDD [434066] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087506 { id="cluster_1087506"; isCluster="true"; label="WholeStageCodegen (1)"; 434068 [id="node_434068" labelType="html" label="MapPartitionsRDD [434068] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087505 { id="cluster_1087505"; isCluster="true"; label="HashAggregate"; 434069 [id="node_434069" labelType="html" label="MapPartitionsRDD [434069] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087504 { id="cluster_1087504"; isCluster="true"; label="Exchange"; 434070 [id="node_434070" labelType="html" label="MapPartitionsRDD [434070] start at FileStorageAdapterImpl.java:596}"]; } } 434064->434065; 434065->434066; 434066->434067; 434067->434068; 434068->434069; 434069->434070; }

digraph G { id="graph_1032497"; subgraph graph_stage_1032497 { id="graph_stage_1032497"; isCluster="true"; label="Stage 1032497"; subgraph cluster_1087504 { id="cluster_1087504"; isCluster="true"; label="Exchange"; 434071 [id="node_434071" labelType="html" label="ShuffledRowRDD [434071] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087501 { id="cluster_1087501"; isCluster="true"; label="WholeStageCodegen (2)"; 434072 [id="node_434072" labelType="html" label="MapPartitionsRDD [434072] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087500 { id="cluster_1087500"; isCluster="true"; label="Exchange"; 434073 [id="node_434073" labelType="html" label="MapPartitionsRDD [434073] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 434071->434072; 434072->434073; }

434070,434071

digraph G { id="graph_1032498"; subgraph graph_stage_1032498 { id="graph_stage_1032498"; isCluster="true"; label="Stage 1032498"; subgraph cluster_1087500 { id="cluster_1087500"; isCluster="true"; label="Exchange"; 434074 [id="node_434074" labelType="html" label="ShuffledRowRDD [434074] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087499 { id="cluster_1087499"; isCluster="true"; label="InMemoryTableScan"; 434075 [id="node_434075" labelType="html" label="MapPartitionsRDD [434075] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 434076 [id="node_434076" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#9675734L, 30), REPARTITION_BY_NUM, [plan_id=3017737]\n+- *(2) HashAggregate(keys=[demandChannel#9675737, shardId#9675733, kpis#9675739, version#9675735, qty#9675736, worklistShardItemId#9675734L, demandStream#9675738], functions=[], output=[shardId#9675733, worklistShardItemId#9675734L, version#9675735, qty#9675736, demandChannel#9675737, demandStream#9675738, kpis#9675739])\n +- Exchange hashpartitioning(demandChannel#9675737, shardId#9675733, kpis#9675739, version#9675735, qty#9675736, worklistShardItemId#9675734L, demandStream#9675738, 30), ENSURE_REQUIREMENTS, [plan_id=3017733]\n +- HashAggregate(keys=[demandChannel#9675737, shardId#9675733, knownfloatingpointnormalized(transform(kpis#9675739, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#10205592)) null else named_struct(label, lambda arg#10205592.label, dateTime, lambda arg#10205592.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#10205592.value)))), lam... [434076] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 434077 [id="node_434077" labelType="html" label="MapPartitionsRDD [434077] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 434078 [id="node_434078" labelType="html" label="MapPartitionsRDD [434078] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 434079 [id="node_434079" labelType="html" label="MapPartitionsRDD [434079] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087496 { id="cluster_1087496"; isCluster="true"; label="WholeStageCodegen (1)"; 434080 [id="node_434080" labelType="html" label="MapPartitionsRDD [434080] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087495 { id="cluster_1087495"; isCluster="true"; label="Exchange"; 434081 [id="node_434081" labelType="html" label="MapPartitionsRDD [434081] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 434074->434075; 434075->434076; 434076->434077; 434077->434078; 434078->434079; 434079->434080; 434080->434081; }

434073,434074

434076

digraph G { id="graph_1032499"; subgraph graph_stage_1032499 { id="graph_stage_1032499"; isCluster="true"; label="Stage 1032499"; subgraph cluster_1087495 { id="cluster_1087495"; isCluster="true"; label="Exchange"; 434082 [id="node_434082" labelType="html" label="ShuffledRowRDD [434082] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087492 { id="cluster_1087492"; isCluster="true"; label="WholeStageCodegen (2)"; 434083 [id="node_434083" labelType="html" label="MapPartitionsRDD [434083] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087508 { id="cluster_1087508"; isCluster="true"; label="mapPartitionsInternal"; 434084 [id="node_434084" labelType="html" label="MapPartitionsRDD [434084] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 434082->434083; 434083->434084; }

434081,434082

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1032499	tenants-pool-506	stream-10000000540-2 id = 386dabc1-f677-44f7-82d8-69fe99072c2c runId = 1ebd557e-9283-4610-a07b-41d13bb785c5 batch = 31 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 14:15:14	0.1 s	30/30	2.8 KiB
1032498	tenants-pool-506	stream-10000000540-2 id = 386dabc1-f677-44f7-82d8-69fe99072c2c runId = 1ebd557e-9283-4610-a07b-41d13bb785c5 batch = 31 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 14:15:13	0.9 s	30/30	16.2 MiB	2.8 KiB
1032497	tenants-pool-506	stream-10000000540-2 id = 386dabc1-f677-44f7-82d8-69fe99072c2c runId = 1ebd557e-9283-4610-a07b-41d13bb785c5 batch = 31 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 14:15:12	0.5 s	30/30	15.9 MiB	16.2 MiB
1032496	tenants-pool-506	stream-10000000540-2 id = 386dabc1-f677-44f7-82d8-69fe99072c2c runId = 1ebd557e-9283-4610-a07b-41d13bb785c5 batch = 31 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 14:15:10	2 s	30/30		15.9 MiB

Page: