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

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

Enable zooming

digraph G { id="graph_1255154"; subgraph graph_stage_1255154 { id="graph_stage_1255154"; isCluster="true"; label="Stage 1255154"; 330441 [id="node_330441" labelType="html" label="SQLExecutionRDD [330441] start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_850091 { id="cluster_850091"; isCluster="true"; label="Scan parquet "; 330438 [id="node_330438" labelType="html" label="FileScanRDD [330438] start at FileStorageAdapterImpl.java:567}"]; 330439 [id="node_330439" labelType="html" label="MapPartitionsRDD [330439] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850088 { id="cluster_850088"; isCluster="true"; label="WholeStageCodegen (1)"; 330440 [id="node_330440" labelType="html" label="MapPartitionsRDD [330440] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850106 { id="cluster_850106"; isCluster="true"; label="WholeStageCodegen (1)"; 330442 [id="node_330442" labelType="html" label="MapPartitionsRDD [330442] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850105 { id="cluster_850105"; isCluster="true"; label="HashAggregate"; 330443 [id="node_330443" labelType="html" label="MapPartitionsRDD [330443] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850104 { id="cluster_850104"; isCluster="true"; label="Exchange"; 330444 [id="node_330444" labelType="html" label="MapPartitionsRDD [330444] start at FileStorageAdapterImpl.java:567}"]; } } 330438->330439; 330439->330440; 330440->330441; 330441->330442; 330442->330443; 330443->330444; }

digraph G { id="graph_1255155"; subgraph graph_stage_1255155 { id="graph_stage_1255155"; isCluster="true"; label="Stage 1255155"; subgraph cluster_850104 { id="cluster_850104"; isCluster="true"; label="Exchange"; 330445 [id="node_330445" labelType="html" label="ShuffledRowRDD [330445] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850101 { id="cluster_850101"; isCluster="true"; label="WholeStageCodegen (2)"; 330446 [id="node_330446" labelType="html" label="MapPartitionsRDD [330446] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850100 { id="cluster_850100"; isCluster="true"; label="Exchange"; 330447 [id="node_330447" labelType="html" label="MapPartitionsRDD [330447] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 330445->330446; 330446->330447; }

330444,330445

digraph G { id="graph_1255156"; subgraph graph_stage_1255156 { id="graph_stage_1255156"; isCluster="true"; label="Stage 1255156"; subgraph cluster_850100 { id="cluster_850100"; isCluster="true"; label="Exchange"; 330448 [id="node_330448" labelType="html" label="ShuffledRowRDD [330448] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850099 { id="cluster_850099"; isCluster="true"; label="InMemoryTableScan"; 330449 [id="node_330449" labelType="html" label="MapPartitionsRDD [330449] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 330450 [id="node_330450" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#5176552L, 30), REPARTITION_BY_NUM, [plan_id=2606325]\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=2606321]\n +- HashAggregate(keys=[demandChannel#5176555, shardId#5176551, knownfloatingpointnormalized(transform(kpis#5176557, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5575107)) null else named_struct(label, lambda arg#5575107.label, dateTime, lambda arg#5575107.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5575107.value)))), lambda ... [330450] [Cached] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 330451 [id="node_330451" labelType="html" label="MapPartitionsRDD [330451] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 330452 [id="node_330452" labelType="html" label="MapPartitionsRDD [330452] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 330453 [id="node_330453" labelType="html" label="MapPartitionsRDD [330453] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850096 { id="cluster_850096"; isCluster="true"; label="WholeStageCodegen (1)"; 330454 [id="node_330454" labelType="html" label="MapPartitionsRDD [330454] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850095 { id="cluster_850095"; isCluster="true"; label="Exchange"; 330455 [id="node_330455" labelType="html" label="MapPartitionsRDD [330455] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 330448->330449; 330449->330450; 330450->330451; 330451->330452; 330452->330453; 330453->330454; 330454->330455; }

330447,330448

330450

digraph G { id="graph_1255157"; subgraph graph_stage_1255157 { id="graph_stage_1255157"; isCluster="true"; label="Stage 1255157"; subgraph cluster_850095 { id="cluster_850095"; isCluster="true"; label="Exchange"; 330456 [id="node_330456" labelType="html" label="ShuffledRowRDD [330456] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850092 { id="cluster_850092"; isCluster="true"; label="WholeStageCodegen (2)"; 330457 [id="node_330457" labelType="html" label="MapPartitionsRDD [330457] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_850108 { id="cluster_850108"; isCluster="true"; label="mapPartitionsInternal"; 330458 [id="node_330458" labelType="html" label="MapPartitionsRDD [330458] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 330456->330457; 330457->330458; }

330455,330456

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1255157	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 35 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:04:03	0.1 s	30/30	1920.0 B
1255156	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 35 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:04:02	0.4 s	30/30	54.0 KiB	1920.0 B
1255155	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 35 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:04:02	0.1 s	30/30	57.5 KiB	54.0 KiB
1255154	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 35 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:04:01	0.5 s	29/29		57.5 KiB

Page: