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

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

Enable zooming

digraph G { id="graph_1254129"; subgraph graph_stage_1254129 { id="graph_stage_1254129"; isCluster="true"; label="Stage 1254129"; 330181 [id="node_330181" labelType="html" label="SQLExecutionRDD [330181] start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_849407 { id="cluster_849407"; isCluster="true"; label="Scan parquet "; 330178 [id="node_330178" labelType="html" label="FileScanRDD [330178] start at FileStorageAdapterImpl.java:567}"]; 330179 [id="node_330179" labelType="html" label="MapPartitionsRDD [330179] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849404 { id="cluster_849404"; isCluster="true"; label="WholeStageCodegen (1)"; 330180 [id="node_330180" labelType="html" label="MapPartitionsRDD [330180] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849422 { id="cluster_849422"; isCluster="true"; label="WholeStageCodegen (1)"; 330182 [id="node_330182" labelType="html" label="MapPartitionsRDD [330182] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849421 { id="cluster_849421"; isCluster="true"; label="HashAggregate"; 330183 [id="node_330183" labelType="html" label="MapPartitionsRDD [330183] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849420 { id="cluster_849420"; isCluster="true"; label="Exchange"; 330184 [id="node_330184" labelType="html" label="MapPartitionsRDD [330184] start at FileStorageAdapterImpl.java:567}"]; } } 330178->330179; 330179->330180; 330180->330181; 330181->330182; 330182->330183; 330183->330184; }

digraph G { id="graph_1254130"; subgraph graph_stage_1254130 { id="graph_stage_1254130"; isCluster="true"; label="Stage 1254130"; subgraph cluster_849420 { id="cluster_849420"; isCluster="true"; label="Exchange"; 330185 [id="node_330185" labelType="html" label="ShuffledRowRDD [330185] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849417 { id="cluster_849417"; isCluster="true"; label="WholeStageCodegen (2)"; 330186 [id="node_330186" labelType="html" label="MapPartitionsRDD [330186] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849416 { id="cluster_849416"; isCluster="true"; label="Exchange"; 330187 [id="node_330187" labelType="html" label="MapPartitionsRDD [330187] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 330185->330186; 330186->330187; }

330184,330185

digraph G { id="graph_1254131"; subgraph graph_stage_1254131 { id="graph_stage_1254131"; isCluster="true"; label="Stage 1254131"; subgraph cluster_849416 { id="cluster_849416"; isCluster="true"; label="Exchange"; 330188 [id="node_330188" labelType="html" label="ShuffledRowRDD [330188] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849415 { id="cluster_849415"; isCluster="true"; label="InMemoryTableScan"; 330189 [id="node_330189" labelType="html" label="MapPartitionsRDD [330189] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 330190 [id="node_330190" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#5176552L, 30), REPARTITION_BY_NUM, [plan_id=2604549]\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=2604545]\n +- HashAggregate(keys=[demandChannel#5176555, shardId#5176551, knownfloatingpointnormalized(transform(kpis#5176557, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5573183)) null else named_struct(label, lambda arg#5573183.label, dateTime, lambda arg#5573183.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5573183.value)))), lambda ... [330190] [Cached] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 330191 [id="node_330191" labelType="html" label="MapPartitionsRDD [330191] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 330192 [id="node_330192" labelType="html" label="MapPartitionsRDD [330192] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 330193 [id="node_330193" labelType="html" label="MapPartitionsRDD [330193] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849412 { id="cluster_849412"; isCluster="true"; label="WholeStageCodegen (1)"; 330194 [id="node_330194" labelType="html" label="MapPartitionsRDD [330194] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849411 { id="cluster_849411"; isCluster="true"; label="Exchange"; 330195 [id="node_330195" labelType="html" label="MapPartitionsRDD [330195] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 330188->330189; 330189->330190; 330190->330191; 330191->330192; 330192->330193; 330193->330194; 330194->330195; }

330187,330188

330190

digraph G { id="graph_1254132"; subgraph graph_stage_1254132 { id="graph_stage_1254132"; isCluster="true"; label="Stage 1254132"; subgraph cluster_849411 { id="cluster_849411"; isCluster="true"; label="Exchange"; 330196 [id="node_330196" labelType="html" label="ShuffledRowRDD [330196] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849408 { id="cluster_849408"; isCluster="true"; label="WholeStageCodegen (2)"; 330197 [id="node_330197" labelType="html" label="MapPartitionsRDD [330197] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849424 { id="cluster_849424"; isCluster="true"; label="mapPartitionsInternal"; 330198 [id="node_330198" labelType="html" label="MapPartitionsRDD [330198] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 330196->330197; 330197->330198; }

330195,330196

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1254132	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 34 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:03:18	0.1 s	30/30	2.1 KiB
1254131	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 34 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:03:17	0.4 s	30/30	55.9 KiB	2.1 KiB
1254130	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 34 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:03:17	0.1 s	30/30	57.1 KiB	55.9 KiB
1254129	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 34 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:03:16	0.7 s	30/30		57.1 KiB

Page: