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

Status: SUCCEEDED
Submitted: 2026/07/22 02:19:45
Duration: 0.5 s
Associated SQL Query: 41149
Job Group: 8fdff9a8-5e79-4dc5-83bf-49d519329d02
Completed Stages: 4

Enable zooming

digraph G { id="graph_1566179"; subgraph graph_stage_1566179 { id="graph_stage_1566179"; isCluster="true"; label="Stage 1566179"; 465791 [id="node_465791" labelType="html" label="SQLExecutionRDD [465791] start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_1227468 { id="cluster_1227468"; isCluster="true"; label="Scan parquet "; 465788 [id="node_465788" labelType="html" label="FileScanRDD [465788] start at FileStorageAdapterImpl.java:598}"]; 465789 [id="node_465789" labelType="html" label="MapPartitionsRDD [465789] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1227465 { id="cluster_1227465"; isCluster="true"; label="WholeStageCodegen (1)"; 465790 [id="node_465790" labelType="html" label="MapPartitionsRDD [465790] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1227483 { id="cluster_1227483"; isCluster="true"; label="WholeStageCodegen (1)"; 465792 [id="node_465792" labelType="html" label="MapPartitionsRDD [465792] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1227482 { id="cluster_1227482"; isCluster="true"; label="HashAggregate"; 465793 [id="node_465793" labelType="html" label="MapPartitionsRDD [465793] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1227481 { id="cluster_1227481"; isCluster="true"; label="Exchange"; 465794 [id="node_465794" labelType="html" label="MapPartitionsRDD [465794] start at FileStorageAdapterImpl.java:598}"]; } } 465788->465789; 465789->465790; 465790->465791; 465791->465792; 465792->465793; 465793->465794; }

digraph G { id="graph_1566180"; subgraph graph_stage_1566180 { id="graph_stage_1566180"; isCluster="true"; label="Stage 1566180"; subgraph cluster_1227481 { id="cluster_1227481"; isCluster="true"; label="Exchange"; 465795 [id="node_465795" labelType="html" label="ShuffledRowRDD [465795] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1227478 { id="cluster_1227478"; isCluster="true"; label="WholeStageCodegen (2)"; 465796 [id="node_465796" labelType="html" label="MapPartitionsRDD [465796] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1227477 { id="cluster_1227477"; isCluster="true"; label="Exchange"; 465797 [id="node_465797" labelType="html" label="MapPartitionsRDD [465797] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 465795->465796; 465796->465797; }

465794,465795

digraph G { id="graph_1566181"; subgraph graph_stage_1566181 { id="graph_stage_1566181"; isCluster="true"; label="Stage 1566181"; subgraph cluster_1227477 { id="cluster_1227477"; isCluster="true"; label="Exchange"; 465798 [id="node_465798" labelType="html" label="ShuffledRowRDD [465798] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1227476 { id="cluster_1227476"; isCluster="true"; label="InMemoryTableScan"; 465799 [id="node_465799" labelType="html" label="MapPartitionsRDD [465799] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 465800 [id="node_465800" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#6420878L, 30), REPARTITION_BY_NUM, [plan_id=3459112]\n+- *(2) HashAggregate(keys=[demandChannel#6420881, shardId#6420877, kpis#6420883, version#6420879, qty#6420880, worklistShardItemId#6420878L, demandStream#6420882], functions=[], output=[shardId#6420877, worklistShardItemId#6420878L, version#6420879, qty#6420880, demandChannel#6420881, demandStream#6420882, kpis#6420883])\n +- Exchange hashpartitioning(demandChannel#6420881, shardId#6420877, kpis#6420883, version#6420879, qty#6420880, worklistShardItemId#6420878L, demandStream#6420882, 30), ENSURE_REQUIREMENTS, [plan_id=3459108]\n +- HashAggregate(keys=[demandChannel#6420881, shardId#6420877, knownfloatingpointnormalized(transform(kpis#6420883, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#6591140)) null else named_struct(label, lambda arg#6591140.label, dateTime, lambda arg#6591140.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#6591140.value)))), lambda ... [465800] [Cached] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 465801 [id="node_465801" labelType="html" label="MapPartitionsRDD [465801] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 465802 [id="node_465802" labelType="html" label="MapPartitionsRDD [465802] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 465803 [id="node_465803" labelType="html" label="MapPartitionsRDD [465803] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1227473 { id="cluster_1227473"; isCluster="true"; label="WholeStageCodegen (1)"; 465804 [id="node_465804" labelType="html" label="MapPartitionsRDD [465804] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1227472 { id="cluster_1227472"; isCluster="true"; label="Exchange"; 465805 [id="node_465805" labelType="html" label="MapPartitionsRDD [465805] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 465798->465799; 465799->465800; 465800->465801; 465801->465802; 465802->465803; 465803->465804; 465804->465805; }

465797,465798

465800

digraph G { id="graph_1566182"; subgraph graph_stage_1566182 { id="graph_stage_1566182"; isCluster="true"; label="Stage 1566182"; subgraph cluster_1227472 { id="cluster_1227472"; isCluster="true"; label="Exchange"; 465806 [id="node_465806" labelType="html" label="ShuffledRowRDD [465806] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1227469 { id="cluster_1227469"; isCluster="true"; label="WholeStageCodegen (2)"; 465807 [id="node_465807" labelType="html" label="MapPartitionsRDD [465807] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1227485 { id="cluster_1227485"; isCluster="true"; label="mapPartitionsInternal"; 465808 [id="node_465808" labelType="html" label="MapPartitionsRDD [465808] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 465806->465807; 465807->465808; }

465805,465806

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1566182	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 43 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/07/22 02:19:46	30 ms	30/30	192.0 B
1566181	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 43 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/07/22 02:19:45	72 ms	30/30	5.4 KiB	192.0 B
1566180	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 43 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/07/22 02:19:45	0.1 s	30/30	5.7 KiB	5.4 KiB
1566179	tenants-pool-679	stream-10000002290-1 id = 9de6f34f-766f-4f9e-a20a-4d04550271a4 runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02 batch = 43 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/07/22 02:19:45	0.3 s	11/11		5.7 KiB

Page: