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

Status: SUCCEEDED
Submitted: 2026/08/31 14:16:59
Duration: 3 s
Associated SQL Query: 13328
Job Group: 9672435e-271f-4f72-bc82-76031aa42a7a
Completed Stages: 4

Enable zooming

digraph G { id="graph_332340"; subgraph graph_stage_332340 { id="graph_stage_332340"; isCluster="true"; label="Stage 332340"; 151815 [id="node_151815" labelType="html" label="SQLExecutionRDD [151815] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_379701 { id="cluster_379701"; isCluster="true"; label="Scan parquet "; 151812 [id="node_151812" labelType="html" label="FileScanRDD [151812] start at FileStorageAdapterImpl.java:596}"]; 151813 [id="node_151813" labelType="html" label="MapPartitionsRDD [151813] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379698 { id="cluster_379698"; isCluster="true"; label="WholeStageCodegen (1)"; 151814 [id="node_151814" labelType="html" label="MapPartitionsRDD [151814] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379716 { id="cluster_379716"; isCluster="true"; label="WholeStageCodegen (1)"; 151816 [id="node_151816" labelType="html" label="MapPartitionsRDD [151816] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379715 { id="cluster_379715"; isCluster="true"; label="HashAggregate"; 151817 [id="node_151817" labelType="html" label="MapPartitionsRDD [151817] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379714 { id="cluster_379714"; isCluster="true"; label="Exchange"; 151818 [id="node_151818" labelType="html" label="MapPartitionsRDD [151818] start at FileStorageAdapterImpl.java:596}"]; } } 151812->151813; 151813->151814; 151814->151815; 151815->151816; 151816->151817; 151817->151818; }

digraph G { id="graph_332341"; subgraph graph_stage_332341 { id="graph_stage_332341"; isCluster="true"; label="Stage 332341"; subgraph cluster_379714 { id="cluster_379714"; isCluster="true"; label="Exchange"; 151819 [id="node_151819" labelType="html" label="ShuffledRowRDD [151819] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379711 { id="cluster_379711"; isCluster="true"; label="WholeStageCodegen (2)"; 151820 [id="node_151820" labelType="html" label="MapPartitionsRDD [151820] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379710 { id="cluster_379710"; isCluster="true"; label="Exchange"; 151821 [id="node_151821" labelType="html" label="MapPartitionsRDD [151821] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151819->151820; 151820->151821; }

151818,151819

digraph G { id="graph_332342"; subgraph graph_stage_332342 { id="graph_stage_332342"; isCluster="true"; label="Stage 332342"; subgraph cluster_379710 { id="cluster_379710"; isCluster="true"; label="Exchange"; 151822 [id="node_151822" labelType="html" label="ShuffledRowRDD [151822] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379709 { id="cluster_379709"; isCluster="true"; label="InMemoryTableScan"; 151823 [id="node_151823" labelType="html" label="MapPartitionsRDD [151823] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151824 [id="node_151824" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3571687L, 30), REPARTITION_BY_NUM, [plan_id=1022398]\n+- *(2) HashAggregate(keys=[demandChannel#3571690, shardId#3571686, kpis#3571692, version#3571688, qty#3571689, worklistShardItemId#3571687L, demandStream#3571691], functions=[], output=[shardId#3571686, worklistShardItemId#3571687L, version#3571688, qty#3571689, demandChannel#3571690, demandStream#3571691, kpis#3571692])\n +- Exchange hashpartitioning(demandChannel#3571690, shardId#3571686, kpis#3571692, version#3571688, qty#3571689, worklistShardItemId#3571687L, demandStream#3571691, 30), ENSURE_REQUIREMENTS, [plan_id=1022394]\n +- HashAggregate(keys=[demandChannel#3571690, shardId#3571686, knownfloatingpointnormalized(transform(kpis#3571692, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3573722)) null else named_struct(label, lambda arg#3573722.label, dateTime, lambda arg#3573722.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3573722.value)))), lambda ... [151824] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151825 [id="node_151825" labelType="html" label="MapPartitionsRDD [151825] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151826 [id="node_151826" labelType="html" label="MapPartitionsRDD [151826] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 151827 [id="node_151827" labelType="html" label="MapPartitionsRDD [151827] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379706 { id="cluster_379706"; isCluster="true"; label="WholeStageCodegen (1)"; 151828 [id="node_151828" labelType="html" label="MapPartitionsRDD [151828] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379705 { id="cluster_379705"; isCluster="true"; label="Exchange"; 151829 [id="node_151829" labelType="html" label="MapPartitionsRDD [151829] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151822->151823; 151823->151824; 151824->151825; 151825->151826; 151826->151827; 151827->151828; 151828->151829; }

151821,151822

151824

digraph G { id="graph_332343"; subgraph graph_stage_332343 { id="graph_stage_332343"; isCluster="true"; label="Stage 332343"; subgraph cluster_379705 { id="cluster_379705"; isCluster="true"; label="Exchange"; 151830 [id="node_151830" labelType="html" label="ShuffledRowRDD [151830] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379702 { id="cluster_379702"; isCluster="true"; label="WholeStageCodegen (2)"; 151831 [id="node_151831" labelType="html" label="MapPartitionsRDD [151831] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379718 { id="cluster_379718"; isCluster="true"; label="mapPartitionsInternal"; 151832 [id="node_151832" labelType="html" label="MapPartitionsRDD [151832] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 151830->151831; 151831->151832; }

151829,151830

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
332343	tenants-pool-506	stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 9672435e-271f-4f72-bc82-76031aa42a7a batch = 20 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:17:02	0.3 s	30/30	2.8 KiB
332342	tenants-pool-506	stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 9672435e-271f-4f72-bc82-76031aa42a7a batch = 20 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:17:01	0.4 s	30/30	5.5 MiB	2.8 KiB
332341	tenants-pool-506	stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 9672435e-271f-4f72-bc82-76031aa42a7a batch = 20 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:17:00	1 s	30/30	5.6 MiB	5.5 MiB
332340	tenants-pool-506	stream-10000000532-1 id = e1173103-f818-4d2c-b463-7c331a0a318e runId = 9672435e-271f-4f72-bc82-76031aa42a7a batch = 20 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:16:59	0.8 s	30/30		5.6 MiB

Page: