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

Status: SUCCEEDED
Submitted: 2026/09/02 14:12:07
Duration: 6 s
Associated SQL Query: 62284
Job Group: 432de182-90ef-401a-b07f-36da93045e0f
Completed Stages: 4

Enable zooming

digraph G { id="graph_1656121"; subgraph graph_stage_1656121 { id="graph_stage_1656121"; isCluster="true"; label="Stage 1656121"; 709760 [id="node_709760" labelType="html" label="SQLExecutionRDD [709760] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1779417 { id="cluster_1779417"; isCluster="true"; label="Scan parquet "; 709757 [id="node_709757" labelType="html" label="FileScanRDD [709757] start at FileStorageAdapterImpl.java:596}"]; 709758 [id="node_709758" labelType="html" label="MapPartitionsRDD [709758] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779414 { id="cluster_1779414"; isCluster="true"; label="WholeStageCodegen (1)"; 709759 [id="node_709759" labelType="html" label="MapPartitionsRDD [709759] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779432 { id="cluster_1779432"; isCluster="true"; label="WholeStageCodegen (1)"; 709761 [id="node_709761" labelType="html" label="MapPartitionsRDD [709761] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779431 { id="cluster_1779431"; isCluster="true"; label="HashAggregate"; 709762 [id="node_709762" labelType="html" label="MapPartitionsRDD [709762] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779430 { id="cluster_1779430"; isCluster="true"; label="Exchange"; 709763 [id="node_709763" labelType="html" label="MapPartitionsRDD [709763] start at FileStorageAdapterImpl.java:596}"]; } } 709757->709758; 709758->709759; 709759->709760; 709760->709761; 709761->709762; 709762->709763; }

digraph G { id="graph_1656122"; subgraph graph_stage_1656122 { id="graph_stage_1656122"; isCluster="true"; label="Stage 1656122"; subgraph cluster_1779430 { id="cluster_1779430"; isCluster="true"; label="Exchange"; 709764 [id="node_709764" labelType="html" label="ShuffledRowRDD [709764] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779427 { id="cluster_1779427"; isCluster="true"; label="WholeStageCodegen (2)"; 709765 [id="node_709765" labelType="html" label="MapPartitionsRDD [709765] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779426 { id="cluster_1779426"; isCluster="true"; label="Exchange"; 709766 [id="node_709766" labelType="html" label="MapPartitionsRDD [709766] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 709764->709765; 709765->709766; }

709763,709764

digraph G { id="graph_1656123"; subgraph graph_stage_1656123 { id="graph_stage_1656123"; isCluster="true"; label="Stage 1656123"; subgraph cluster_1779426 { id="cluster_1779426"; isCluster="true"; label="Exchange"; 709767 [id="node_709767" labelType="html" label="ShuffledRowRDD [709767] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779425 { id="cluster_1779425"; isCluster="true"; label="InMemoryTableScan"; 709768 [id="node_709768" labelType="html" label="MapPartitionsRDD [709768] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709769 [id="node_709769" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#16692472L, 30), REPARTITION_BY_NUM, [plan_id=4962784]\n+- *(2) HashAggregate(keys=[demandChannel#16692475, shardId#16692471, kpis#16692477, version#16692473, qty#16692474, worklistShardItemId#16692472L, demandStream#16692476], functions=[], output=[shardId#16692471, worklistShardItemId#16692472L, version#16692473, qty#16692474, demandChannel#16692475, demandStream#16692476, kpis#16692477])\n +- Exchange hashpartitioning(demandChannel#16692475, shardId#16692471, kpis#16692477, version#16692473, qty#16692474, worklistShardItemId#16692472L, demandStream#16692476, 30), ENSURE_REQUIREMENTS, [plan_id=4962780]\n +- HashAggregate(keys=[demandChannel#16692475, shardId#16692471, knownfloatingpointnormalized(transform(kpis#16692477, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#16692564)) null else named_struct(label, lambda arg#16692564.label, dateTime, lambda arg#16692564.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [709769] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709770 [id="node_709770" labelType="html" label="MapPartitionsRDD [709770] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709771 [id="node_709771" labelType="html" label="MapPartitionsRDD [709771] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709772 [id="node_709772" labelType="html" label="MapPartitionsRDD [709772] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779422 { id="cluster_1779422"; isCluster="true"; label="WholeStageCodegen (1)"; 709773 [id="node_709773" labelType="html" label="MapPartitionsRDD [709773] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779421 { id="cluster_1779421"; isCluster="true"; label="Exchange"; 709774 [id="node_709774" labelType="html" label="MapPartitionsRDD [709774] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 709767->709768; 709768->709769; 709769->709770; 709770->709771; 709771->709772; 709772->709773; 709773->709774; }

709766,709767

709769

digraph G { id="graph_1656124"; subgraph graph_stage_1656124 { id="graph_stage_1656124"; isCluster="true"; label="Stage 1656124"; subgraph cluster_1779421 { id="cluster_1779421"; isCluster="true"; label="Exchange"; 709775 [id="node_709775" labelType="html" label="ShuffledRowRDD [709775] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779418 { id="cluster_1779418"; isCluster="true"; label="WholeStageCodegen (2)"; 709776 [id="node_709776" labelType="html" label="MapPartitionsRDD [709776] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779434 { id="cluster_1779434"; isCluster="true"; label="mapPartitionsInternal"; 709777 [id="node_709777" labelType="html" label="MapPartitionsRDD [709777] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 709775->709776; 709776->709777; }

709774,709775

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1656124	tenants-pool-506	stream-10000000548-1 id = afd22577-8db0-418a-852e-0495de3b86e3 runId = 432de182-90ef-401a-b07f-36da93045e0f batch = 7 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:12	0.6 s	30/30	2.8 KiB
1656123	tenants-pool-506	stream-10000000548-1 id = afd22577-8db0-418a-852e-0495de3b86e3 runId = 432de182-90ef-401a-b07f-36da93045e0f batch = 7 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:11	1 s	30/30	13.7 MiB	2.8 KiB
1656122	tenants-pool-506	stream-10000000548-1 id = afd22577-8db0-418a-852e-0495de3b86e3 runId = 432de182-90ef-401a-b07f-36da93045e0f batch = 7 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:10	0.6 s	30/30	13.5 MiB	13.7 MiB
1656121	tenants-pool-506	stream-10000000548-1 id = afd22577-8db0-418a-852e-0495de3b86e3 runId = 432de182-90ef-401a-b07f-36da93045e0f batch = 7 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:07	3 s	30/30		13.5 MiB

Page: