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

Status: SUCCEEDED
Submitted: 2026/05/22 09:33:55
Duration: 1 s
Associated SQL Query: 24824
Job Group: 65cb8160-40af-4a1d-9ef7-845fbd048abf
Completed Stages: 4

Enable zooming

digraph G { id="graph_1276064"; subgraph graph_stage_1276064 { id="graph_stage_1276064"; isCluster="true"; label="Stage 1276064"; 336232 [id="node_336232" labelType="html" label="SQLExecutionRDD [336232] start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_864867 { id="cluster_864867"; isCluster="true"; label="Scan parquet "; 336229 [id="node_336229" labelType="html" label="FileScanRDD [336229] start at FileStorageAdapterImpl.java:567}"]; 336230 [id="node_336230" labelType="html" label="MapPartitionsRDD [336230] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_864864 { id="cluster_864864"; isCluster="true"; label="WholeStageCodegen (1)"; 336231 [id="node_336231" labelType="html" label="MapPartitionsRDD [336231] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_864882 { id="cluster_864882"; isCluster="true"; label="WholeStageCodegen (1)"; 336233 [id="node_336233" labelType="html" label="MapPartitionsRDD [336233] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_864881 { id="cluster_864881"; isCluster="true"; label="HashAggregate"; 336234 [id="node_336234" labelType="html" label="MapPartitionsRDD [336234] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_864880 { id="cluster_864880"; isCluster="true"; label="Exchange"; 336235 [id="node_336235" labelType="html" label="MapPartitionsRDD [336235] start at FileStorageAdapterImpl.java:567}"]; } } 336229->336230; 336230->336231; 336231->336232; 336232->336233; 336233->336234; 336234->336235; }

digraph G { id="graph_1276065"; subgraph graph_stage_1276065 { id="graph_stage_1276065"; isCluster="true"; label="Stage 1276065"; subgraph cluster_864880 { id="cluster_864880"; isCluster="true"; label="Exchange"; 336236 [id="node_336236" labelType="html" label="ShuffledRowRDD [336236] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_864877 { id="cluster_864877"; isCluster="true"; label="WholeStageCodegen (2)"; 336237 [id="node_336237" labelType="html" label="MapPartitionsRDD [336237] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_864876 { id="cluster_864876"; isCluster="true"; label="Exchange"; 336238 [id="node_336238" labelType="html" label="MapPartitionsRDD [336238] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 336236->336237; 336237->336238; }

336235,336236

digraph G { id="graph_1276066"; subgraph graph_stage_1276066 { id="graph_stage_1276066"; isCluster="true"; label="Stage 1276066"; subgraph cluster_864876 { id="cluster_864876"; isCluster="true"; label="Exchange"; 336239 [id="node_336239" labelType="html" label="ShuffledRowRDD [336239] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_864875 { id="cluster_864875"; isCluster="true"; label="InMemoryTableScan"; 336240 [id="node_336240" labelType="html" label="MapPartitionsRDD [336240] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 336241 [id="node_336241" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#5661070L, 30), REPARTITION_BY_NUM, [plan_id=2649996]\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=2649992]\n +- HashAggregate(keys=[demandChannel#5661073, shardId#5661069, knownfloatingpointnormalized(transform(kpis#5661075, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5681705)) null else named_struct(label, lambda arg#5681705.label, dateTime, lambda arg#5681705.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5681705.value)))), lambda ... [336241] [Cached] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 336242 [id="node_336242" labelType="html" label="MapPartitionsRDD [336242] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 336243 [id="node_336243" labelType="html" label="MapPartitionsRDD [336243] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 336244 [id="node_336244" labelType="html" label="MapPartitionsRDD [336244] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_864872 { id="cluster_864872"; isCluster="true"; label="WholeStageCodegen (1)"; 336245 [id="node_336245" labelType="html" label="MapPartitionsRDD [336245] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_864871 { id="cluster_864871"; isCluster="true"; label="Exchange"; 336246 [id="node_336246" labelType="html" label="MapPartitionsRDD [336246] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 336239->336240; 336240->336241; 336241->336242; 336242->336243; 336243->336244; 336244->336245; 336245->336246; }

336238,336239

336241

digraph G { id="graph_1276067"; subgraph graph_stage_1276067 { id="graph_stage_1276067"; isCluster="true"; label="Stage 1276067"; subgraph cluster_864871 { id="cluster_864871"; isCluster="true"; label="Exchange"; 336247 [id="node_336247" labelType="html" label="ShuffledRowRDD [336247] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_864868 { id="cluster_864868"; isCluster="true"; label="WholeStageCodegen (2)"; 336248 [id="node_336248" labelType="html" label="MapPartitionsRDD [336248] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_864884 { id="cluster_864884"; isCluster="true"; label="mapPartitionsInternal"; 336249 [id="node_336249" labelType="html" label="MapPartitionsRDD [336249] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 336247->336248; 336248->336249; }

336246,336247

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1276067	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 3 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:33:56	24 ms	30/30	672.0 B
1276066	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 3 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:33:56	0.2 s	30/30	18.8 KiB	672.0 B
1276065	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 3 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:33:56	0.2 s	30/30	19.6 KiB	18.8 KiB
1276064	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 3 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:33:55	0.8 s	25/25		19.6 KiB

Page: