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

Status: SUCCEEDED
Submitted: 2026/05/22 09:47:45
Duration: 0.8 s
Associated SQL Query: 25429
Job Group: 65cb8160-40af-4a1d-9ef7-845fbd048abf
Completed Stages: 4

Enable zooming

digraph G { id="graph_1318880"; subgraph graph_stage_1318880 { id="graph_stage_1318880"; isCluster="true"; label="Stage 1318880"; 344182 [id="node_344182" labelType="html" label="SQLExecutionRDD [344182] start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_885436 { id="cluster_885436"; isCluster="true"; label="Scan parquet "; 344179 [id="node_344179" labelType="html" label="FileScanRDD [344179] start at FileStorageAdapterImpl.java:567}"]; 344180 [id="node_344180" labelType="html" label="MapPartitionsRDD [344180] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_885433 { id="cluster_885433"; isCluster="true"; label="WholeStageCodegen (1)"; 344181 [id="node_344181" labelType="html" label="MapPartitionsRDD [344181] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_885451 { id="cluster_885451"; isCluster="true"; label="WholeStageCodegen (1)"; 344183 [id="node_344183" labelType="html" label="MapPartitionsRDD [344183] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_885450 { id="cluster_885450"; isCluster="true"; label="HashAggregate"; 344184 [id="node_344184" labelType="html" label="MapPartitionsRDD [344184] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_885449 { id="cluster_885449"; isCluster="true"; label="Exchange"; 344185 [id="node_344185" labelType="html" label="MapPartitionsRDD [344185] start at FileStorageAdapterImpl.java:567}"]; } } 344179->344180; 344180->344181; 344181->344182; 344182->344183; 344183->344184; 344184->344185; }

digraph G { id="graph_1318881"; subgraph graph_stage_1318881 { id="graph_stage_1318881"; isCluster="true"; label="Stage 1318881"; subgraph cluster_885449 { id="cluster_885449"; isCluster="true"; label="Exchange"; 344186 [id="node_344186" labelType="html" label="ShuffledRowRDD [344186] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_885446 { id="cluster_885446"; isCluster="true"; label="WholeStageCodegen (2)"; 344187 [id="node_344187" labelType="html" label="MapPartitionsRDD [344187] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_885445 { id="cluster_885445"; isCluster="true"; label="Exchange"; 344188 [id="node_344188" labelType="html" label="MapPartitionsRDD [344188] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 344186->344187; 344187->344188; }

344185,344186

digraph G { id="graph_1318882"; subgraph graph_stage_1318882 { id="graph_stage_1318882"; isCluster="true"; label="Stage 1318882"; subgraph cluster_885445 { id="cluster_885445"; isCluster="true"; label="Exchange"; 344189 [id="node_344189" labelType="html" label="ShuffledRowRDD [344189] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_885444 { id="cluster_885444"; isCluster="true"; label="InMemoryTableScan"; 344190 [id="node_344190" labelType="html" label="MapPartitionsRDD [344190] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 344191 [id="node_344191" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#5661070L, 30), REPARTITION_BY_NUM, [plan_id=2703313]\n+- *(2) HashAggregate(keys=[demandChannel#5661073, shardId#5661069, kpis#5661075, version#5661071, qty#5661072, worklistShardItemId#5661070L, demandStream#5661074], functions=[], output=[shardId#5661069, worklistShardItemId#5661070L, version#5661071, qty#5661072, demandChannel#5661073, demandStream#5661074, kpis#5661075])\n +- Exchange hashpartitioning(demandChannel#5661073, shardId#5661069, kpis#5661075, version#5661071, qty#5661072, worklistShardItemId#5661070L, demandStream#5661074, 30), ENSURE_REQUIREMENTS, [plan_id=2703309]\n +- HashAggregate(keys=[demandChannel#5661073, shardId#5661069, knownfloatingpointnormalized(transform(kpis#5661075, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5781730)) null else named_struct(label, lambda arg#5781730.label, dateTime, lambda arg#5781730.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5781730.value)))), lambda ... [344191] [Cached] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 344192 [id="node_344192" labelType="html" label="MapPartitionsRDD [344192] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 344193 [id="node_344193" labelType="html" label="MapPartitionsRDD [344193] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 344194 [id="node_344194" labelType="html" label="MapPartitionsRDD [344194] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_885441 { id="cluster_885441"; isCluster="true"; label="WholeStageCodegen (1)"; 344195 [id="node_344195" labelType="html" label="MapPartitionsRDD [344195] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_885440 { id="cluster_885440"; isCluster="true"; label="Exchange"; 344196 [id="node_344196" labelType="html" label="MapPartitionsRDD [344196] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 344189->344190; 344190->344191; 344191->344192; 344192->344193; 344193->344194; 344194->344195; 344195->344196; }

344188,344189

344191

digraph G { id="graph_1318883"; subgraph graph_stage_1318883 { id="graph_stage_1318883"; isCluster="true"; label="Stage 1318883"; subgraph cluster_885440 { id="cluster_885440"; isCluster="true"; label="Exchange"; 344197 [id="node_344197" labelType="html" label="ShuffledRowRDD [344197] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_885437 { id="cluster_885437"; isCluster="true"; label="WholeStageCodegen (2)"; 344198 [id="node_344198" labelType="html" label="MapPartitionsRDD [344198] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_885453 { id="cluster_885453"; isCluster="true"; label="mapPartitionsInternal"; 344199 [id="node_344199" labelType="html" label="MapPartitionsRDD [344199] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 344197->344198; 344198->344199; }

344196,344197

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1318883	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 28 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:47:46	0.1 s	30/30	96.0 B
1318882	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 28 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:47:45	0.4 s	30/30	872.0 B	96.0 B
1318881	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 28 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:47:45	0.1 s	30/30	860.0 B	872.0 B
1318880	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 28 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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/05/22 09:47:45	0.2 s	2/2		860.0 B

Page: