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

Status: SUCCEEDED
Submitted: 2026/05/22 09:12:07
Duration: 1 s
Associated SQL Query: 24644
Job Group: 10d36e12-5b96-4752-9e6b-ca062fdd8807
Completed Stages: 4

Enable zooming

digraph G { id="graph_1272863"; subgraph graph_stage_1272863 { id="graph_stage_1272863"; isCluster="true"; label="Stage 1272863"; 334052 [id="node_334052" labelType="html" label="SQLExecutionRDD [334052] start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_859228 { id="cluster_859228"; isCluster="true"; label="Scan parquet "; 334049 [id="node_334049" labelType="html" label="FileScanRDD [334049] start at FileStorageAdapterImpl.java:567}"]; 334050 [id="node_334050" labelType="html" label="MapPartitionsRDD [334050] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859225 { id="cluster_859225"; isCluster="true"; label="WholeStageCodegen (1)"; 334051 [id="node_334051" labelType="html" label="MapPartitionsRDD [334051] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859243 { id="cluster_859243"; isCluster="true"; label="WholeStageCodegen (1)"; 334053 [id="node_334053" labelType="html" label="MapPartitionsRDD [334053] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859242 { id="cluster_859242"; isCluster="true"; label="HashAggregate"; 334054 [id="node_334054" labelType="html" label="MapPartitionsRDD [334054] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859241 { id="cluster_859241"; isCluster="true"; label="Exchange"; 334055 [id="node_334055" labelType="html" label="MapPartitionsRDD [334055] start at FileStorageAdapterImpl.java:567}"]; } } 334049->334050; 334050->334051; 334051->334052; 334052->334053; 334053->334054; 334054->334055; }

digraph G { id="graph_1272864"; subgraph graph_stage_1272864 { id="graph_stage_1272864"; isCluster="true"; label="Stage 1272864"; subgraph cluster_859241 { id="cluster_859241"; isCluster="true"; label="Exchange"; 334056 [id="node_334056" labelType="html" label="ShuffledRowRDD [334056] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859238 { id="cluster_859238"; isCluster="true"; label="WholeStageCodegen (2)"; 334057 [id="node_334057" labelType="html" label="MapPartitionsRDD [334057] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859237 { id="cluster_859237"; isCluster="true"; label="Exchange"; 334058 [id="node_334058" labelType="html" label="MapPartitionsRDD [334058] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 334056->334057; 334057->334058; }

334055,334056

digraph G { id="graph_1272865"; subgraph graph_stage_1272865 { id="graph_stage_1272865"; isCluster="true"; label="Stage 1272865"; subgraph cluster_859237 { id="cluster_859237"; isCluster="true"; label="Exchange"; 334059 [id="node_334059" labelType="html" label="ShuffledRowRDD [334059] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859236 { id="cluster_859236"; isCluster="true"; label="InMemoryTableScan"; 334060 [id="node_334060" labelType="html" label="MapPartitionsRDD [334060] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 334061 [id="node_334061" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#5176552L, 30), REPARTITION_BY_NUM, [plan_id=2629630]\n+- *(2) HashAggregate(keys=[demandChannel#5176555, shardId#5176551, kpis#5176557, version#5176553, qty#5176554, worklistShardItemId#5176552L, demandStream#5176556], functions=[], output=[shardId#5176551, worklistShardItemId#5176552L, version#5176553, qty#5176554, demandChannel#5176555, demandStream#5176556, kpis#5176557])\n +- Exchange hashpartitioning(demandChannel#5176555, shardId#5176551, kpis#5176557, version#5176553, qty#5176554, worklistShardItemId#5176552L, demandStream#5176556, 30), ENSURE_REQUIREMENTS, [plan_id=2629626]\n +- HashAggregate(keys=[demandChannel#5176555, shardId#5176551, knownfloatingpointnormalized(transform(kpis#5176557, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5642081)) null else named_struct(label, lambda arg#5642081.label, dateTime, lambda arg#5642081.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5642081.value)))), lambda ... [334061] [Cached] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 334062 [id="node_334062" labelType="html" label="MapPartitionsRDD [334062] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 334063 [id="node_334063" labelType="html" label="MapPartitionsRDD [334063] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 334064 [id="node_334064" labelType="html" label="MapPartitionsRDD [334064] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859233 { id="cluster_859233"; isCluster="true"; label="WholeStageCodegen (1)"; 334065 [id="node_334065" labelType="html" label="MapPartitionsRDD [334065] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859232 { id="cluster_859232"; isCluster="true"; label="Exchange"; 334066 [id="node_334066" labelType="html" label="MapPartitionsRDD [334066] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 334059->334060; 334060->334061; 334061->334062; 334062->334063; 334063->334064; 334064->334065; 334065->334066; }

334058,334059

334061

digraph G { id="graph_1272866"; subgraph graph_stage_1272866 { id="graph_stage_1272866"; isCluster="true"; label="Stage 1272866"; subgraph cluster_859232 { id="cluster_859232"; isCluster="true"; label="Exchange"; 334067 [id="node_334067" labelType="html" label="ShuffledRowRDD [334067] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859229 { id="cluster_859229"; isCluster="true"; label="WholeStageCodegen (2)"; 334068 [id="node_334068" labelType="html" label="MapPartitionsRDD [334068] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_859245 { id="cluster_859245"; isCluster="true"; label="mapPartitionsInternal"; 334069 [id="node_334069" labelType="html" label="MapPartitionsRDD [334069] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 334067->334068; 334068->334069; }

334066,334067

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1272866	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 43 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:12:08	0.1 s	30/30	576.0 B
1272865	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 43 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:12:07	0.4 s	30/30	4.9 KiB	576.0 B
1272864	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 43 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:12:07	0.1 s	30/30	4.8 KiB	4.9 KiB
1272863	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 43 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:12:07	0.5 s	11/11		4.8 KiB

Page: