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

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

Enable zooming

digraph G { id="graph_1338391"; subgraph graph_stage_1338391 { id="graph_stage_1338391"; isCluster="true"; label="Stage 1338391"; 394104 [id="node_394104" labelType="html" label="SQLExecutionRDD [394104] start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_1037999 { id="cluster_1037999"; isCluster="true"; label="Scan parquet "; 394101 [id="node_394101" labelType="html" label="FileScanRDD [394101] start at FileStorageAdapterImpl.java:598}"]; 394102 [id="node_394102" labelType="html" label="MapPartitionsRDD [394102] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1037996 { id="cluster_1037996"; isCluster="true"; label="WholeStageCodegen (1)"; 394103 [id="node_394103" labelType="html" label="MapPartitionsRDD [394103] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038014 { id="cluster_1038014"; isCluster="true"; label="WholeStageCodegen (1)"; 394105 [id="node_394105" labelType="html" label="MapPartitionsRDD [394105] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038013 { id="cluster_1038013"; isCluster="true"; label="HashAggregate"; 394106 [id="node_394106" labelType="html" label="MapPartitionsRDD [394106] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038012 { id="cluster_1038012"; isCluster="true"; label="Exchange"; 394107 [id="node_394107" labelType="html" label="MapPartitionsRDD [394107] start at FileStorageAdapterImpl.java:598}"]; } } 394101->394102; 394102->394103; 394103->394104; 394104->394105; 394105->394106; 394106->394107; }

digraph G { id="graph_1338392"; subgraph graph_stage_1338392 { id="graph_stage_1338392"; isCluster="true"; label="Stage 1338392"; subgraph cluster_1038012 { id="cluster_1038012"; isCluster="true"; label="Exchange"; 394108 [id="node_394108" labelType="html" label="ShuffledRowRDD [394108] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038009 { id="cluster_1038009"; isCluster="true"; label="WholeStageCodegen (2)"; 394109 [id="node_394109" labelType="html" label="MapPartitionsRDD [394109] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038008 { id="cluster_1038008"; isCluster="true"; label="Exchange"; 394110 [id="node_394110" labelType="html" label="MapPartitionsRDD [394110] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 394108->394109; 394109->394110; }

394107,394108

digraph G { id="graph_1338393"; subgraph graph_stage_1338393 { id="graph_stage_1338393"; isCluster="true"; label="Stage 1338393"; subgraph cluster_1038008 { id="cluster_1038008"; isCluster="true"; label="Exchange"; 394111 [id="node_394111" labelType="html" label="ShuffledRowRDD [394111] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038007 { id="cluster_1038007"; isCluster="true"; label="InMemoryTableScan"; 394112 [id="node_394112" labelType="html" label="MapPartitionsRDD [394112] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 394113 [id="node_394113" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#4883822L, 30), REPARTITION_BY_NUM, [plan_id=2898869]\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=2898865]\n +- HashAggregate(keys=[demandChannel#4883825, shardId#4883821, knownfloatingpointnormalized(transform(kpis#4883827, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5587733)) null else named_struct(label, lambda arg#5587733.label, dateTime, lambda arg#5587733.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5587733.value)))), lambda ... [394113] [Cached] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 394114 [id="node_394114" labelType="html" label="MapPartitionsRDD [394114] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 394115 [id="node_394115" labelType="html" label="MapPartitionsRDD [394115] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 394116 [id="node_394116" labelType="html" label="MapPartitionsRDD [394116] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038004 { id="cluster_1038004"; isCluster="true"; label="WholeStageCodegen (1)"; 394117 [id="node_394117" labelType="html" label="MapPartitionsRDD [394117] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038003 { id="cluster_1038003"; isCluster="true"; label="Exchange"; 394118 [id="node_394118" labelType="html" label="MapPartitionsRDD [394118] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 394111->394112; 394112->394113; 394113->394114; 394114->394115; 394115->394116; 394116->394117; 394117->394118; }

394110,394111

394113

digraph G { id="graph_1338394"; subgraph graph_stage_1338394 { id="graph_stage_1338394"; isCluster="true"; label="Stage 1338394"; subgraph cluster_1038003 { id="cluster_1038003"; isCluster="true"; label="Exchange"; 394119 [id="node_394119" labelType="html" label="ShuffledRowRDD [394119] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038000 { id="cluster_1038000"; isCluster="true"; label="WholeStageCodegen (2)"; 394120 [id="node_394120" labelType="html" label="MapPartitionsRDD [394120] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1038016 { id="cluster_1038016"; isCluster="true"; label="mapPartitionsInternal"; 394121 [id="node_394121" labelType="html" label="MapPartitionsRDD [394121] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 394119->394120; 394120->394121; }

394118,394119

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1338394	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 100 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:11	31 ms	30/30	96.0 B
1338393	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 100 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:11	0.1 s	30/30	1216.0 B	96.0 B
1338392	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 100 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:11	94 ms	30/30	1190.0 B	1216.0 B
1338391	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 100 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:11	0.3 s	2/2		1190.0 B

Page: