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

Status: SUCCEEDED
Submitted: 2026/07/21 20:58:40
Duration: 0.5 s
Associated SQL Query: 34766
Job Group: 881110fc-a22e-43dd-9ef6-858dd65243b7
Completed Stages: 4

Enable zooming

digraph G { id="graph_1339962"; subgraph graph_stage_1339962 { id="graph_stage_1339962"; isCluster="true"; label="Stage 1339962"; 394364 [id="node_394364" labelType="html" label="SQLExecutionRDD [394364] start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_1038695 { id="cluster_1038695"; isCluster="true"; label="Scan parquet "; 394361 [id="node_394361" labelType="html" label="FileScanRDD [394361] start at FileStorageAdapterImpl.java:598}"]; 394362 [id="node_394362" labelType="html" label="MapPartitionsRDD [394362] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038692 { id="cluster_1038692"; isCluster="true"; label="WholeStageCodegen (1)"; 394363 [id="node_394363" labelType="html" label="MapPartitionsRDD [394363] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038710 { id="cluster_1038710"; isCluster="true"; label="WholeStageCodegen (1)"; 394365 [id="node_394365" labelType="html" label="MapPartitionsRDD [394365] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038709 { id="cluster_1038709"; isCluster="true"; label="HashAggregate"; 394366 [id="node_394366" labelType="html" label="MapPartitionsRDD [394366] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038708 { id="cluster_1038708"; isCluster="true"; label="Exchange"; 394367 [id="node_394367" labelType="html" label="MapPartitionsRDD [394367] start at FileStorageAdapterImpl.java:598}"]; } } 394361->394362; 394362->394363; 394363->394364; 394364->394365; 394365->394366; 394366->394367; }

digraph G { id="graph_1339963"; subgraph graph_stage_1339963 { id="graph_stage_1339963"; isCluster="true"; label="Stage 1339963"; subgraph cluster_1038708 { id="cluster_1038708"; isCluster="true"; label="Exchange"; 394368 [id="node_394368" labelType="html" label="ShuffledRowRDD [394368] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038705 { id="cluster_1038705"; isCluster="true"; label="WholeStageCodegen (2)"; 394369 [id="node_394369" labelType="html" label="MapPartitionsRDD [394369] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038704 { id="cluster_1038704"; isCluster="true"; label="Exchange"; 394370 [id="node_394370" labelType="html" label="MapPartitionsRDD [394370] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 394368->394369; 394369->394370; }

394367,394368

digraph G { id="graph_1339964"; subgraph graph_stage_1339964 { id="graph_stage_1339964"; isCluster="true"; label="Stage 1339964"; subgraph cluster_1038704 { id="cluster_1038704"; isCluster="true"; label="Exchange"; 394371 [id="node_394371" labelType="html" label="ShuffledRowRDD [394371] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038703 { id="cluster_1038703"; isCluster="true"; label="InMemoryTableScan"; 394372 [id="node_394372" labelType="html" label="MapPartitionsRDD [394372] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 394373 [id="node_394373" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#4883822L, 30), REPARTITION_BY_NUM, [plan_id=2900691]\n+- *(2) HashAggregate(keys=[demandChannel#4883825, shardId#4883821, kpis#4883827, version#4883823, qty#4883824, worklistShardItemId#4883822L, demandStream#4883826], functions=[], output=[shardId#4883821, worklistShardItemId#4883822L, version#4883823, qty#4883824, demandChannel#4883825, demandStream#4883826, kpis#4883827])\n +- Exchange hashpartitioning(demandChannel#4883825, shardId#4883821, kpis#4883827, version#4883823, qty#4883824, worklistShardItemId#4883822L, demandStream#4883826, 30), ENSURE_REQUIREMENTS, [plan_id=2900687]\n +- HashAggregate(keys=[demandChannel#4883825, shardId#4883821, knownfloatingpointnormalized(transform(kpis#4883827, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5590109)) null else named_struct(label, lambda arg#5590109.label, dateTime, lambda arg#5590109.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5590109.value)))), lambda ... [394373] [Cached] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 394374 [id="node_394374" labelType="html" label="MapPartitionsRDD [394374] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 394375 [id="node_394375" labelType="html" label="MapPartitionsRDD [394375] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 394376 [id="node_394376" labelType="html" label="MapPartitionsRDD [394376] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038700 { id="cluster_1038700"; isCluster="true"; label="WholeStageCodegen (1)"; 394377 [id="node_394377" labelType="html" label="MapPartitionsRDD [394377] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038699 { id="cluster_1038699"; isCluster="true"; label="Exchange"; 394378 [id="node_394378" labelType="html" label="MapPartitionsRDD [394378] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 394371->394372; 394372->394373; 394373->394374; 394374->394375; 394375->394376; 394376->394377; 394377->394378; }

394370,394371

394373

digraph G { id="graph_1339965"; subgraph graph_stage_1339965 { id="graph_stage_1339965"; isCluster="true"; label="Stage 1339965"; subgraph cluster_1038699 { id="cluster_1038699"; isCluster="true"; label="Exchange"; 394379 [id="node_394379" labelType="html" label="ShuffledRowRDD [394379] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038696 { id="cluster_1038696"; isCluster="true"; label="WholeStageCodegen (2)"; 394380 [id="node_394380" labelType="html" label="MapPartitionsRDD [394380] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038712 { id="cluster_1038712"; isCluster="true"; label="mapPartitionsInternal"; 394381 [id="node_394381" labelType="html" label="MapPartitionsRDD [394381] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 394379->394380; 394380->394381; }

394378,394379

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1339965	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 101 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/21 20:58:41	30 ms	30/30	96.0 B
1339964	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 101 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/21 20:58:41	82 ms	30/30	2.4 KiB	96.0 B
1339963	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 101 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/21 20:58:41	37 ms	30/30	2.3 KiB	2.4 KiB
1339962	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 101 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/21 20:58:40	0.4 s	4/4		2.3 KiB

Page: