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

Status: SUCCEEDED
Submitted: 2026/09/02 11:07:11
Duration: 2 s
Associated SQL Query: 58594
Job Group: ecadee06-9c12-4d07-90ed-fadaaeb04186
Completed Stages: 4

Enable zooming

digraph G { id="graph_1519633"; subgraph graph_stage_1519633 { id="graph_stage_1519633"; isCluster="true"; label="Stage 1519633"; 667559 [id="node_667559" labelType="html" label="SQLExecutionRDD [667559] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1673971 { id="cluster_1673971"; isCluster="true"; label="Scan parquet "; 667556 [id="node_667556" labelType="html" label="FileScanRDD [667556] start at FileStorageAdapterImpl.java:596}"]; 667557 [id="node_667557" labelType="html" label="MapPartitionsRDD [667557] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673968 { id="cluster_1673968"; isCluster="true"; label="WholeStageCodegen (1)"; 667558 [id="node_667558" labelType="html" label="MapPartitionsRDD [667558] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673986 { id="cluster_1673986"; isCluster="true"; label="WholeStageCodegen (1)"; 667560 [id="node_667560" labelType="html" label="MapPartitionsRDD [667560] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673985 { id="cluster_1673985"; isCluster="true"; label="HashAggregate"; 667561 [id="node_667561" labelType="html" label="MapPartitionsRDD [667561] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673984 { id="cluster_1673984"; isCluster="true"; label="Exchange"; 667562 [id="node_667562" labelType="html" label="MapPartitionsRDD [667562] start at FileStorageAdapterImpl.java:596}"]; } } 667556->667557; 667557->667558; 667558->667559; 667559->667560; 667560->667561; 667561->667562; }

digraph G { id="graph_1519634"; subgraph graph_stage_1519634 { id="graph_stage_1519634"; isCluster="true"; label="Stage 1519634"; subgraph cluster_1673984 { id="cluster_1673984"; isCluster="true"; label="Exchange"; 667563 [id="node_667563" labelType="html" label="ShuffledRowRDD [667563] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673981 { id="cluster_1673981"; isCluster="true"; label="WholeStageCodegen (2)"; 667564 [id="node_667564" labelType="html" label="MapPartitionsRDD [667564] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673980 { id="cluster_1673980"; isCluster="true"; label="Exchange"; 667565 [id="node_667565" labelType="html" label="MapPartitionsRDD [667565] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 667563->667564; 667564->667565; }

667562,667563

digraph G { id="graph_1519635"; subgraph graph_stage_1519635 { id="graph_stage_1519635"; isCluster="true"; label="Stage 1519635"; subgraph cluster_1673980 { id="cluster_1673980"; isCluster="true"; label="Exchange"; 667566 [id="node_667566" labelType="html" label="ShuffledRowRDD [667566] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673979 { id="cluster_1673979"; isCluster="true"; label="InMemoryTableScan"; 667567 [id="node_667567" labelType="html" label="MapPartitionsRDD [667567] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 667568 [id="node_667568" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#15242296L, 30), REPARTITION_BY_NUM, [plan_id=4687558]\n+- *(2) HashAggregate(keys=[demandChannel#15242299, shardId#15242295, kpis#15242301, version#15242297, qty#15242298, worklistShardItemId#15242296L, demandStream#15242300], functions=[], output=[shardId#15242295, worklistShardItemId#15242296L, version#15242297, qty#15242298, demandChannel#15242299, demandStream#15242300, kpis#15242301])\n +- Exchange hashpartitioning(demandChannel#15242299, shardId#15242295, kpis#15242301, version#15242297, qty#15242298, worklistShardItemId#15242296L, demandStream#15242300, 30), ENSURE_REQUIREMENTS, [plan_id=4687554]\n +- HashAggregate(keys=[demandChannel#15242299, shardId#15242295, knownfloatingpointnormalized(transform(kpis#15242301, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#15686449)) null else named_struct(label, lambda arg#15686449.label, dateTime, lambda arg#15686449.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [667568] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 667569 [id="node_667569" labelType="html" label="MapPartitionsRDD [667569] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 667570 [id="node_667570" labelType="html" label="MapPartitionsRDD [667570] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 667571 [id="node_667571" labelType="html" label="MapPartitionsRDD [667571] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673976 { id="cluster_1673976"; isCluster="true"; label="WholeStageCodegen (1)"; 667572 [id="node_667572" labelType="html" label="MapPartitionsRDD [667572] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673975 { id="cluster_1673975"; isCluster="true"; label="Exchange"; 667573 [id="node_667573" labelType="html" label="MapPartitionsRDD [667573] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 667566->667567; 667567->667568; 667568->667569; 667569->667570; 667570->667571; 667571->667572; 667572->667573; }

667565,667566

667568

digraph G { id="graph_1519636"; subgraph graph_stage_1519636 { id="graph_stage_1519636"; isCluster="true"; label="Stage 1519636"; subgraph cluster_1673975 { id="cluster_1673975"; isCluster="true"; label="Exchange"; 667574 [id="node_667574" labelType="html" label="ShuffledRowRDD [667574] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673972 { id="cluster_1673972"; isCluster="true"; label="WholeStageCodegen (2)"; 667575 [id="node_667575" labelType="html" label="MapPartitionsRDD [667575] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1673988 { id="cluster_1673988"; isCluster="true"; label="mapPartitionsInternal"; 667576 [id="node_667576" labelType="html" label="MapPartitionsRDD [667576] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 667574->667575; 667575->667576; }

667573,667574

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1519636	tenants-pool-506	stream-10000000545-3 id = da94c279-6b4e-482d-aee8-cfb437fd7812 runId = ecadee06-9c12-4d07-90ed-fadaaeb04186 batch = 18 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 11:07:13	0.1 s	30/30	2.8 KiB
1519635	tenants-pool-506	stream-10000000545-3 id = da94c279-6b4e-482d-aee8-cfb437fd7812 runId = ecadee06-9c12-4d07-90ed-fadaaeb04186 batch = 18 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 11:07:12	0.6 s	30/30	15.4 MiB	2.8 KiB
1519634	tenants-pool-506	stream-10000000545-3 id = da94c279-6b4e-482d-aee8-cfb437fd7812 runId = ecadee06-9c12-4d07-90ed-fadaaeb04186 batch = 18 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 11:07:12	0.2 s	30/30	15.2 MiB	15.4 MiB
1519633	tenants-pool-506	stream-10000000545-3 id = da94c279-6b4e-482d-aee8-cfb437fd7812 runId = ecadee06-9c12-4d07-90ed-fadaaeb04186 batch = 18 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 11:07:11	0.9 s	30/30		15.2 MiB

Page: