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

Status: SUCCEEDED
Submitted: 2026/09/02 14:12:20
Duration: 2 s
Associated SQL Query: 62292
Job Group: d8ab24cc-742c-44e6-9e5e-19e910f59f22
Completed Stages: 4

Enable zooming

digraph G { id="graph_1656218"; subgraph graph_stage_1656218 { id="graph_stage_1656218"; isCluster="true"; label="Stage 1656218"; 709856 [id="node_709856" labelType="html" label="SQLExecutionRDD [709856] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1779620 { id="cluster_1779620"; isCluster="true"; label="Scan parquet "; 709853 [id="node_709853" labelType="html" label="FileScanRDD [709853] start at FileStorageAdapterImpl.java:596}"]; 709854 [id="node_709854" labelType="html" label="MapPartitionsRDD [709854] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779617 { id="cluster_1779617"; isCluster="true"; label="WholeStageCodegen (1)"; 709855 [id="node_709855" labelType="html" label="MapPartitionsRDD [709855] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779635 { id="cluster_1779635"; isCluster="true"; label="WholeStageCodegen (1)"; 709857 [id="node_709857" labelType="html" label="MapPartitionsRDD [709857] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779634 { id="cluster_1779634"; isCluster="true"; label="HashAggregate"; 709858 [id="node_709858" labelType="html" label="MapPartitionsRDD [709858] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779633 { id="cluster_1779633"; isCluster="true"; label="Exchange"; 709859 [id="node_709859" labelType="html" label="MapPartitionsRDD [709859] start at FileStorageAdapterImpl.java:596}"]; } } 709853->709854; 709854->709855; 709855->709856; 709856->709857; 709857->709858; 709858->709859; }

digraph G { id="graph_1656219"; subgraph graph_stage_1656219 { id="graph_stage_1656219"; isCluster="true"; label="Stage 1656219"; subgraph cluster_1779633 { id="cluster_1779633"; isCluster="true"; label="Exchange"; 709860 [id="node_709860" labelType="html" label="ShuffledRowRDD [709860] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779630 { id="cluster_1779630"; isCluster="true"; label="WholeStageCodegen (2)"; 709861 [id="node_709861" labelType="html" label="MapPartitionsRDD [709861] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779629 { id="cluster_1779629"; isCluster="true"; label="Exchange"; 709862 [id="node_709862" labelType="html" label="MapPartitionsRDD [709862] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 709860->709861; 709861->709862; }

709859,709860

digraph G { id="graph_1656220"; subgraph graph_stage_1656220 { id="graph_stage_1656220"; isCluster="true"; label="Stage 1656220"; subgraph cluster_1779629 { id="cluster_1779629"; isCluster="true"; label="Exchange"; 709863 [id="node_709863" labelType="html" label="ShuffledRowRDD [709863] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779628 { id="cluster_1779628"; isCluster="true"; label="InMemoryTableScan"; 709864 [id="node_709864" labelType="html" label="MapPartitionsRDD [709864] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709865 [id="node_709865" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#16691990L, 30), REPARTITION_BY_NUM, [plan_id=4963238]\n+- *(2) HashAggregate(keys=[demandChannel#16691993, shardId#16691989, kpis#16691995, version#16691991, qty#16691992, worklistShardItemId#16691990L, demandStream#16691994], functions=[], output=[shardId#16691989, worklistShardItemId#16691990L, version#16691991, qty#16691992, demandChannel#16691993, demandStream#16691994, kpis#16691995])\n +- Exchange hashpartitioning(demandChannel#16691993, shardId#16691989, kpis#16691995, version#16691991, qty#16691992, worklistShardItemId#16691990L, demandStream#16691994, 30), ENSURE_REQUIREMENTS, [plan_id=4963234]\n +- HashAggregate(keys=[demandChannel#16691993, shardId#16691989, knownfloatingpointnormalized(transform(kpis#16691995, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#16693702)) null else named_struct(label, lambda arg#16693702.label, dateTime, lambda arg#16693702.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [709865] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709866 [id="node_709866" labelType="html" label="MapPartitionsRDD [709866] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709867 [id="node_709867" labelType="html" label="MapPartitionsRDD [709867] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709868 [id="node_709868" labelType="html" label="MapPartitionsRDD [709868] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779625 { id="cluster_1779625"; isCluster="true"; label="WholeStageCodegen (1)"; 709869 [id="node_709869" labelType="html" label="MapPartitionsRDD [709869] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779624 { id="cluster_1779624"; isCluster="true"; label="Exchange"; 709870 [id="node_709870" labelType="html" label="MapPartitionsRDD [709870] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 709863->709864; 709864->709865; 709865->709866; 709866->709867; 709867->709868; 709868->709869; 709869->709870; }

709862,709863

709865

digraph G { id="graph_1656221"; subgraph graph_stage_1656221 { id="graph_stage_1656221"; isCluster="true"; label="Stage 1656221"; subgraph cluster_1779624 { id="cluster_1779624"; isCluster="true"; label="Exchange"; 709871 [id="node_709871" labelType="html" label="ShuffledRowRDD [709871] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779621 { id="cluster_1779621"; isCluster="true"; label="WholeStageCodegen (2)"; 709872 [id="node_709872" labelType="html" label="MapPartitionsRDD [709872] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779637 { id="cluster_1779637"; isCluster="true"; label="mapPartitionsInternal"; 709873 [id="node_709873" labelType="html" label="MapPartitionsRDD [709873] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 709871->709872; 709872->709873; }

709870,709871

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1656221	tenants-pool-506	stream-10000000548-2 id = e6c89ecb-41f0-4c0d-a2b7-5cd5af2cdfb7 runId = d8ab24cc-742c-44e6-9e5e-19e910f59f22 batch = 39 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 14:12:22	0.1 s	30/30	2.8 KiB
1656220	tenants-pool-506	stream-10000000548-2 id = e6c89ecb-41f0-4c0d-a2b7-5cd5af2cdfb7 runId = d8ab24cc-742c-44e6-9e5e-19e910f59f22 batch = 39 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 14:12:21	0.2 s	30/30	5.0 MiB	2.8 KiB
1656219	tenants-pool-506	stream-10000000548-2 id = e6c89ecb-41f0-4c0d-a2b7-5cd5af2cdfb7 runId = d8ab24cc-742c-44e6-9e5e-19e910f59f22 batch = 39 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 14:12:21	0.1 s	30/30	5.0 MiB	5.0 MiB
1656218	tenants-pool-506	stream-10000000548-2 id = e6c89ecb-41f0-4c0d-a2b7-5cd5af2cdfb7 runId = d8ab24cc-742c-44e6-9e5e-19e910f59f22 batch = 39 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 14:12:20	0.6 s	30/30		5.0 MiB

Page: