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

Status: SUCCEEDED
Submitted: 2026/08/31 14:37:25
Duration: 2 s
Associated SQL Query: 13553
Job Group: 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d
Completed Stages: 4

Enable zooming

digraph G { id="graph_341336"; subgraph graph_stage_341336 { id="graph_stage_341336"; isCluster="true"; label="Stage 341336"; 154491 [id="node_154491" labelType="html" label="SQLExecutionRDD [154491] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_386318 { id="cluster_386318"; isCluster="true"; label="Scan parquet "; 154488 [id="node_154488" labelType="html" label="FileScanRDD [154488] start at FileStorageAdapterImpl.java:596}"]; 154489 [id="node_154489" labelType="html" label="MapPartitionsRDD [154489] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_386315 { id="cluster_386315"; isCluster="true"; label="WholeStageCodegen (1)"; 154490 [id="node_154490" labelType="html" label="MapPartitionsRDD [154490] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_386333 { id="cluster_386333"; isCluster="true"; label="WholeStageCodegen (1)"; 154492 [id="node_154492" labelType="html" label="MapPartitionsRDD [154492] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_386332 { id="cluster_386332"; isCluster="true"; label="HashAggregate"; 154493 [id="node_154493" labelType="html" label="MapPartitionsRDD [154493] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_386331 { id="cluster_386331"; isCluster="true"; label="Exchange"; 154494 [id="node_154494" labelType="html" label="MapPartitionsRDD [154494] start at FileStorageAdapterImpl.java:596}"]; } } 154488->154489; 154489->154490; 154490->154491; 154491->154492; 154492->154493; 154493->154494; }

digraph G { id="graph_341337"; subgraph graph_stage_341337 { id="graph_stage_341337"; isCluster="true"; label="Stage 341337"; subgraph cluster_386331 { id="cluster_386331"; isCluster="true"; label="Exchange"; 154495 [id="node_154495" labelType="html" label="ShuffledRowRDD [154495] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_386328 { id="cluster_386328"; isCluster="true"; label="WholeStageCodegen (2)"; 154496 [id="node_154496" labelType="html" label="MapPartitionsRDD [154496] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_386327 { id="cluster_386327"; isCluster="true"; label="Exchange"; 154497 [id="node_154497" labelType="html" label="MapPartitionsRDD [154497] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154495->154496; 154496->154497; }

154494,154495

digraph G { id="graph_341338"; subgraph graph_stage_341338 { id="graph_stage_341338"; isCluster="true"; label="Stage 341338"; subgraph cluster_386327 { id="cluster_386327"; isCluster="true"; label="Exchange"; 154498 [id="node_154498" labelType="html" label="ShuffledRowRDD [154498] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_386326 { id="cluster_386326"; isCluster="true"; label="InMemoryTableScan"; 154499 [id="node_154499" labelType="html" label="MapPartitionsRDD [154499] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154500 [id="node_154500" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3614461L, 30), REPARTITION_BY_NUM, [plan_id=1037329]\n+- *(2) HashAggregate(keys=[demandChannel#3614464, shardId#3614460, kpis#3614466, version#3614462, qty#3614463, worklistShardItemId#3614461L, demandStream#3614465], functions=[], output=[shardId#3614460, worklistShardItemId#3614461L, version#3614462, qty#3614463, demandChannel#3614464, demandStream#3614465, kpis#3614466])\n +- Exchange hashpartitioning(demandChannel#3614464, shardId#3614460, kpis#3614466, version#3614462, qty#3614463, worklistShardItemId#3614461L, demandStream#3614465, 30), ENSURE_REQUIREMENTS, [plan_id=1037325]\n +- HashAggregate(keys=[demandChannel#3614464, shardId#3614460, knownfloatingpointnormalized(transform(kpis#3614466, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3623877)) null else named_struct(label, lambda arg#3623877.label, dateTime, lambda arg#3623877.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3623877.value)))), lambda ... [154500] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154501 [id="node_154501" labelType="html" label="MapPartitionsRDD [154501] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154502 [id="node_154502" labelType="html" label="MapPartitionsRDD [154502] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154503 [id="node_154503" labelType="html" label="MapPartitionsRDD [154503] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_386323 { id="cluster_386323"; isCluster="true"; label="WholeStageCodegen (1)"; 154504 [id="node_154504" labelType="html" label="MapPartitionsRDD [154504] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_386322 { id="cluster_386322"; isCluster="true"; label="Exchange"; 154505 [id="node_154505" labelType="html" label="MapPartitionsRDD [154505] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154498->154499; 154499->154500; 154500->154501; 154501->154502; 154502->154503; 154503->154504; 154504->154505; }

154497,154498

154500

digraph G { id="graph_341339"; subgraph graph_stage_341339 { id="graph_stage_341339"; isCluster="true"; label="Stage 341339"; subgraph cluster_386322 { id="cluster_386322"; isCluster="true"; label="Exchange"; 154506 [id="node_154506" labelType="html" label="ShuffledRowRDD [154506] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_386319 { id="cluster_386319"; isCluster="true"; label="WholeStageCodegen (2)"; 154507 [id="node_154507" labelType="html" label="MapPartitionsRDD [154507] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_386335 { id="cluster_386335"; isCluster="true"; label="mapPartitionsInternal"; 154508 [id="node_154508" labelType="html" label="MapPartitionsRDD [154508] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154506->154507; 154507->154508; }

154505,154506

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
341339	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d 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/08/31 14:37:27	0.3 s	30/30	2.8 KiB
341338	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d 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/08/31 14:37:27	0.5 s	30/30	16.3 MiB	2.8 KiB
341337	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d 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/08/31 14:37:26	0.3 s	30/30	16.0 MiB	16.3 MiB
341336	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d 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/08/31 14:37:25	1 s	30/30		16.0 MiB

Page: