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

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

Enable zooming

digraph G { id="graph_1251217"; subgraph graph_stage_1251217 { id="graph_stage_1251217"; isCluster="true"; label="Stage 1251217"; 329156 [id="node_329156" labelType="html" label="SQLExecutionRDD [329156] start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_846836 { id="cluster_846836"; isCluster="true"; label="Scan parquet "; 329153 [id="node_329153" labelType="html" label="FileScanRDD [329153] start at FileStorageAdapterImpl.java:567}"]; 329154 [id="node_329154" labelType="html" label="MapPartitionsRDD [329154] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_846833 { id="cluster_846833"; isCluster="true"; label="WholeStageCodegen (1)"; 329155 [id="node_329155" labelType="html" label="MapPartitionsRDD [329155] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_846851 { id="cluster_846851"; isCluster="true"; label="WholeStageCodegen (1)"; 329157 [id="node_329157" labelType="html" label="MapPartitionsRDD [329157] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_846850 { id="cluster_846850"; isCluster="true"; label="HashAggregate"; 329158 [id="node_329158" labelType="html" label="MapPartitionsRDD [329158] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_846849 { id="cluster_846849"; isCluster="true"; label="Exchange"; 329159 [id="node_329159" labelType="html" label="MapPartitionsRDD [329159] start at FileStorageAdapterImpl.java:567}"]; } } 329153->329154; 329154->329155; 329155->329156; 329156->329157; 329157->329158; 329158->329159; }

digraph G { id="graph_1251218"; subgraph graph_stage_1251218 { id="graph_stage_1251218"; isCluster="true"; label="Stage 1251218"; subgraph cluster_846849 { id="cluster_846849"; isCluster="true"; label="Exchange"; 329160 [id="node_329160" labelType="html" label="ShuffledRowRDD [329160] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_846846 { id="cluster_846846"; isCluster="true"; label="WholeStageCodegen (2)"; 329161 [id="node_329161" labelType="html" label="MapPartitionsRDD [329161] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_846845 { id="cluster_846845"; isCluster="true"; label="Exchange"; 329162 [id="node_329162" labelType="html" label="MapPartitionsRDD [329162] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 329160->329161; 329161->329162; }

329159,329160

digraph G { id="graph_1251219"; subgraph graph_stage_1251219 { id="graph_stage_1251219"; isCluster="true"; label="Stage 1251219"; subgraph cluster_846845 { id="cluster_846845"; isCluster="true"; label="Exchange"; 329163 [id="node_329163" labelType="html" label="ShuffledRowRDD [329163] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_846844 { id="cluster_846844"; isCluster="true"; label="InMemoryTableScan"; 329164 [id="node_329164" labelType="html" label="MapPartitionsRDD [329164] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 329165 [id="node_329165" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#5176552L, 30), REPARTITION_BY_NUM, [plan_id=2598025]\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=2598021]\n +- HashAggregate(keys=[demandChannel#5176555, shardId#5176551, knownfloatingpointnormalized(transform(kpis#5176557, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5552207)) null else named_struct(label, lambda arg#5552207.label, dateTime, lambda arg#5552207.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5552207.value)))), lambda ... [329165] [Cached] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 329166 [id="node_329166" labelType="html" label="MapPartitionsRDD [329166] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 329167 [id="node_329167" labelType="html" label="MapPartitionsRDD [329167] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 329168 [id="node_329168" labelType="html" label="MapPartitionsRDD [329168] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_846841 { id="cluster_846841"; isCluster="true"; label="WholeStageCodegen (1)"; 329169 [id="node_329169" labelType="html" label="MapPartitionsRDD [329169] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_846840 { id="cluster_846840"; isCluster="true"; label="Exchange"; 329170 [id="node_329170" labelType="html" label="MapPartitionsRDD [329170] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 329163->329164; 329164->329165; 329165->329166; 329166->329167; 329167->329168; 329168->329169; 329169->329170; }

329162,329163

329165

digraph G { id="graph_1251220"; subgraph graph_stage_1251220 { id="graph_stage_1251220"; isCluster="true"; label="Stage 1251220"; subgraph cluster_846840 { id="cluster_846840"; isCluster="true"; label="Exchange"; 329171 [id="node_329171" labelType="html" label="ShuffledRowRDD [329171] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_846837 { id="cluster_846837"; isCluster="true"; label="WholeStageCodegen (2)"; 329172 [id="node_329172" labelType="html" label="MapPartitionsRDD [329172] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_846853 { id="cluster_846853"; isCluster="true"; label="mapPartitionsInternal"; 329173 [id="node_329173" labelType="html" label="MapPartitionsRDD [329173] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 329171->329172; 329172->329173; }

329170,329171

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1251220	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 32 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:00:53	0.1 s	30/30	1824.0 B
1251219	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 32 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:00:52	0.5 s	30/30	34.0 KiB	1824.0 B
1251218	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 32 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:00:52	0.1 s	30/30	33.6 KiB	34.0 KiB
1251217	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 32 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:00:51	0.6 s	29/29		33.6 KiB

Page: