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

Status: SUCCEEDED
Submitted: 2026/09/03 11:17:51
Duration: 2 s
Associated SQL Query: 82742
Job Group: 4bf75fd4-c2e3-496e-bc8a-c063a62efe60
Completed Stages: 4

Enable zooming

digraph G { id="graph_2133960"; subgraph graph_stage_2133960 { id="graph_stage_2133960"; isCluster="true"; label="Stage 2133960"; 942977 [id="node_942977" labelType="html" label="SQLExecutionRDD [942977] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_2365730 { id="cluster_2365730"; isCluster="true"; label="Scan parquet "; 942974 [id="node_942974" labelType="html" label="FileScanRDD [942974] start at FileStorageAdapterImpl.java:596}"]; 942975 [id="node_942975" labelType="html" label="MapPartitionsRDD [942975] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2365727 { id="cluster_2365727"; isCluster="true"; label="WholeStageCodegen (1)"; 942976 [id="node_942976" labelType="html" label="MapPartitionsRDD [942976] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2365745 { id="cluster_2365745"; isCluster="true"; label="WholeStageCodegen (1)"; 942978 [id="node_942978" labelType="html" label="MapPartitionsRDD [942978] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2365744 { id="cluster_2365744"; isCluster="true"; label="HashAggregate"; 942979 [id="node_942979" labelType="html" label="MapPartitionsRDD [942979] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2365743 { id="cluster_2365743"; isCluster="true"; label="Exchange"; 942980 [id="node_942980" labelType="html" label="MapPartitionsRDD [942980] start at FileStorageAdapterImpl.java:596}"]; } } 942974->942975; 942975->942976; 942976->942977; 942977->942978; 942978->942979; 942979->942980; }

digraph G { id="graph_2133961"; subgraph graph_stage_2133961 { id="graph_stage_2133961"; isCluster="true"; label="Stage 2133961"; subgraph cluster_2365743 { id="cluster_2365743"; isCluster="true"; label="Exchange"; 942981 [id="node_942981" labelType="html" label="ShuffledRowRDD [942981] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2365740 { id="cluster_2365740"; isCluster="true"; label="WholeStageCodegen (2)"; 942982 [id="node_942982" labelType="html" label="MapPartitionsRDD [942982] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2365739 { id="cluster_2365739"; isCluster="true"; label="Exchange"; 942983 [id="node_942983" labelType="html" label="MapPartitionsRDD [942983] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 942981->942982; 942982->942983; }

942980,942981

digraph G { id="graph_2133962"; subgraph graph_stage_2133962 { id="graph_stage_2133962"; isCluster="true"; label="Stage 2133962"; subgraph cluster_2365739 { id="cluster_2365739"; isCluster="true"; label="Exchange"; 942984 [id="node_942984" labelType="html" label="ShuffledRowRDD [942984] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2365738 { id="cluster_2365738"; isCluster="true"; label="InMemoryTableScan"; 942985 [id="node_942985" labelType="html" label="MapPartitionsRDD [942985] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 942986 [id="node_942986" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#21946660L, 30), REPARTITION_BY_NUM, [plan_id=6643673]\n+- *(2) HashAggregate(keys=[demandChannel#21946663, shardId#21946659, kpis#21946665, version#21946661, qty#21946662, worklistShardItemId#21946660L, demandStream#21946664], functions=[], output=[shardId#21946659, worklistShardItemId#21946660L, version#21946661, qty#21946662, demandChannel#21946663, demandStream#21946664, kpis#21946665])\n +- Exchange hashpartitioning(demandChannel#21946663, shardId#21946659, kpis#21946665, version#21946661, qty#21946662, worklistShardItemId#21946660L, demandStream#21946664, 30), ENSURE_REQUIREMENTS, [plan_id=6643669]\n +- HashAggregate(keys=[demandChannel#21946663, shardId#21946659, knownfloatingpointnormalized(transform(kpis#21946665, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#22196028)) null else named_struct(label, lambda arg#22196028.label, dateTime, lambda arg#22196028.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [942986] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 942987 [id="node_942987" labelType="html" label="MapPartitionsRDD [942987] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 942988 [id="node_942988" labelType="html" label="MapPartitionsRDD [942988] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 942989 [id="node_942989" labelType="html" label="MapPartitionsRDD [942989] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2365735 { id="cluster_2365735"; isCluster="true"; label="WholeStageCodegen (1)"; 942990 [id="node_942990" labelType="html" label="MapPartitionsRDD [942990] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2365734 { id="cluster_2365734"; isCluster="true"; label="Exchange"; 942991 [id="node_942991" labelType="html" label="MapPartitionsRDD [942991] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 942984->942985; 942985->942986; 942986->942987; 942987->942988; 942988->942989; 942989->942990; 942990->942991; }

942983,942984

942986

digraph G { id="graph_2133963"; subgraph graph_stage_2133963 { id="graph_stage_2133963"; isCluster="true"; label="Stage 2133963"; subgraph cluster_2365734 { id="cluster_2365734"; isCluster="true"; label="Exchange"; 942992 [id="node_942992" labelType="html" label="ShuffledRowRDD [942992] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2365731 { id="cluster_2365731"; isCluster="true"; label="WholeStageCodegen (2)"; 942993 [id="node_942993" labelType="html" label="MapPartitionsRDD [942993] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2365747 { id="cluster_2365747"; isCluster="true"; label="mapPartitionsInternal"; 942994 [id="node_942994" labelType="html" label="MapPartitionsRDD [942994] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 942992->942993; 942993->942994; }

942991,942992

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
2133963	tenants-pool-506	stream-10000000553-2 id = 2d18952d-9c0e-4b9a-82c0-f91d822b51c6 runId = 4bf75fd4-c2e3-496e-bc8a-c063a62efe60 batch = 16 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/03 11:17:52	0.1 s	30/30	2.8 KiB
2133962	tenants-pool-506	stream-10000000553-2 id = 2d18952d-9c0e-4b9a-82c0-f91d822b51c6 runId = 4bf75fd4-c2e3-496e-bc8a-c063a62efe60 batch = 16 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/03 11:17:52	0.5 s	30/30	7.1 MiB	2.8 KiB
2133961	tenants-pool-506	stream-10000000553-2 id = 2d18952d-9c0e-4b9a-82c0-f91d822b51c6 runId = 4bf75fd4-c2e3-496e-bc8a-c063a62efe60 batch = 16 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/03 11:17:52	0.2 s	30/30	7.0 MiB	7.1 MiB
2133960	tenants-pool-506	stream-10000000553-2 id = 2d18952d-9c0e-4b9a-82c0-f91d822b51c6 runId = 4bf75fd4-c2e3-496e-bc8a-c063a62efe60 batch = 16 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/03 11:17:51	0.8 s	30/30		7.0 MiB

Page: