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

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

Enable zooming

digraph G { id="graph_1332463"; subgraph graph_stage_1332463 { id="graph_stage_1332463"; isCluster="true"; label="Stage 1332463"; 392768 [id="node_392768" labelType="html" label="SQLExecutionRDD [392768] start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_1034428 { id="cluster_1034428"; isCluster="true"; label="Scan parquet "; 392765 [id="node_392765" labelType="html" label="FileScanRDD [392765] start at FileStorageAdapterImpl.java:598}"]; 392766 [id="node_392766" labelType="html" label="MapPartitionsRDD [392766] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034425 { id="cluster_1034425"; isCluster="true"; label="WholeStageCodegen (1)"; 392767 [id="node_392767" labelType="html" label="MapPartitionsRDD [392767] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034443 { id="cluster_1034443"; isCluster="true"; label="WholeStageCodegen (1)"; 392769 [id="node_392769" labelType="html" label="MapPartitionsRDD [392769] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034442 { id="cluster_1034442"; isCluster="true"; label="HashAggregate"; 392770 [id="node_392770" labelType="html" label="MapPartitionsRDD [392770] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034441 { id="cluster_1034441"; isCluster="true"; label="Exchange"; 392771 [id="node_392771" labelType="html" label="MapPartitionsRDD [392771] start at FileStorageAdapterImpl.java:598}"]; } } 392765->392766; 392766->392767; 392767->392768; 392768->392769; 392769->392770; 392770->392771; }

digraph G { id="graph_1332464"; subgraph graph_stage_1332464 { id="graph_stage_1332464"; isCluster="true"; label="Stage 1332464"; subgraph cluster_1034441 { id="cluster_1034441"; isCluster="true"; label="Exchange"; 392772 [id="node_392772" labelType="html" label="ShuffledRowRDD [392772] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034438 { id="cluster_1034438"; isCluster="true"; label="WholeStageCodegen (2)"; 392773 [id="node_392773" labelType="html" label="MapPartitionsRDD [392773] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034437 { id="cluster_1034437"; isCluster="true"; label="Exchange"; 392774 [id="node_392774" labelType="html" label="MapPartitionsRDD [392774] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 392772->392773; 392773->392774; }

392771,392772

digraph G { id="graph_1332465"; subgraph graph_stage_1332465 { id="graph_stage_1332465"; isCluster="true"; label="Stage 1332465"; subgraph cluster_1034437 { id="cluster_1034437"; isCluster="true"; label="Exchange"; 392775 [id="node_392775" labelType="html" label="ShuffledRowRDD [392775] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034436 { id="cluster_1034436"; isCluster="true"; label="InMemoryTableScan"; 392776 [id="node_392776" labelType="html" label="MapPartitionsRDD [392776] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 392777 [id="node_392777" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#4883822L, 30), REPARTITION_BY_NUM, [plan_id=2889665]\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=2889661]\n +- HashAggregate(keys=[demandChannel#4883825, shardId#4883821, knownfloatingpointnormalized(transform(kpis#4883827, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5575499)) null else named_struct(label, lambda arg#5575499.label, dateTime, lambda arg#5575499.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5575499.value)))), lambda ... [392777] [Cached] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 392778 [id="node_392778" labelType="html" label="MapPartitionsRDD [392778] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 392779 [id="node_392779" labelType="html" label="MapPartitionsRDD [392779] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 392780 [id="node_392780" labelType="html" label="MapPartitionsRDD [392780] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034433 { id="cluster_1034433"; isCluster="true"; label="WholeStageCodegen (1)"; 392781 [id="node_392781" labelType="html" label="MapPartitionsRDD [392781] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034432 { id="cluster_1034432"; isCluster="true"; label="Exchange"; 392782 [id="node_392782" labelType="html" label="MapPartitionsRDD [392782] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 392775->392776; 392776->392777; 392777->392778; 392778->392779; 392779->392780; 392780->392781; 392781->392782; }

392774,392775

392777

digraph G { id="graph_1332466"; subgraph graph_stage_1332466 { id="graph_stage_1332466"; isCluster="true"; label="Stage 1332466"; subgraph cluster_1034432 { id="cluster_1034432"; isCluster="true"; label="Exchange"; 392783 [id="node_392783" labelType="html" label="ShuffledRowRDD [392783] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034429 { id="cluster_1034429"; isCluster="true"; label="WholeStageCodegen (2)"; 392784 [id="node_392784" labelType="html" label="MapPartitionsRDD [392784] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034445 { id="cluster_1034445"; isCluster="true"; label="mapPartitionsInternal"; 392785 [id="node_392785" labelType="html" label="MapPartitionsRDD [392785] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 392783->392784; 392784->392785; }

392782,392783

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1332466	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 95 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:55:56	16 ms	30/30	480.0 B
1332465	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 95 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:55:56	0.1 s	30/30	6.0 KiB	480.0 B
1332464	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 95 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:55:56	40 ms	30/30	5.8 KiB	6.0 KiB
1332463	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 95 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:55:55	0.4 s	9/9		5.8 KiB

Page: