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

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

Enable zooming

digraph G { id="graph_1270688"; subgraph graph_stage_1270688 { id="graph_stage_1270688"; isCluster="true"; label="Stage 1270688"; 333038 [id="node_333038" labelType="html" label="SQLExecutionRDD [333038] start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_856681 { id="cluster_856681"; isCluster="true"; label="Scan parquet "; 333035 [id="node_333035" labelType="html" label="FileScanRDD [333035] start at FileStorageAdapterImpl.java:567}"]; 333036 [id="node_333036" labelType="html" label="MapPartitionsRDD [333036] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856678 { id="cluster_856678"; isCluster="true"; label="WholeStageCodegen (1)"; 333037 [id="node_333037" labelType="html" label="MapPartitionsRDD [333037] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856696 { id="cluster_856696"; isCluster="true"; label="WholeStageCodegen (1)"; 333039 [id="node_333039" labelType="html" label="MapPartitionsRDD [333039] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856695 { id="cluster_856695"; isCluster="true"; label="HashAggregate"; 333040 [id="node_333040" labelType="html" label="MapPartitionsRDD [333040] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856694 { id="cluster_856694"; isCluster="true"; label="Exchange"; 333041 [id="node_333041" labelType="html" label="MapPartitionsRDD [333041] start at FileStorageAdapterImpl.java:567}"]; } } 333035->333036; 333036->333037; 333037->333038; 333038->333039; 333039->333040; 333040->333041; }

digraph G { id="graph_1270689"; subgraph graph_stage_1270689 { id="graph_stage_1270689"; isCluster="true"; label="Stage 1270689"; subgraph cluster_856694 { id="cluster_856694"; isCluster="true"; label="Exchange"; 333042 [id="node_333042" labelType="html" label="ShuffledRowRDD [333042] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856691 { id="cluster_856691"; isCluster="true"; label="WholeStageCodegen (2)"; 333043 [id="node_333043" labelType="html" label="MapPartitionsRDD [333043] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856690 { id="cluster_856690"; isCluster="true"; label="Exchange"; 333044 [id="node_333044" labelType="html" label="MapPartitionsRDD [333044] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 333042->333043; 333043->333044; }

333041,333042

digraph G { id="graph_1270690"; subgraph graph_stage_1270690 { id="graph_stage_1270690"; isCluster="true"; label="Stage 1270690"; subgraph cluster_856690 { id="cluster_856690"; isCluster="true"; label="Exchange"; 333045 [id="node_333045" labelType="html" label="ShuffledRowRDD [333045] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856689 { id="cluster_856689"; isCluster="true"; label="InMemoryTableScan"; 333046 [id="node_333046" labelType="html" label="MapPartitionsRDD [333046] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 333047 [id="node_333047" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#5176552L, 30), REPARTITION_BY_NUM, [plan_id=2623138]\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=2623134]\n +- HashAggregate(keys=[demandChannel#5176555, shardId#5176551, knownfloatingpointnormalized(transform(kpis#5176557, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5621189)) null else named_struct(label, lambda arg#5621189.label, dateTime, lambda arg#5621189.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5621189.value)))), lambda ... [333047] [Cached] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 333048 [id="node_333048" labelType="html" label="MapPartitionsRDD [333048] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 333049 [id="node_333049" labelType="html" label="MapPartitionsRDD [333049] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 333050 [id="node_333050" labelType="html" label="MapPartitionsRDD [333050] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856686 { id="cluster_856686"; isCluster="true"; label="WholeStageCodegen (1)"; 333051 [id="node_333051" labelType="html" label="MapPartitionsRDD [333051] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856685 { id="cluster_856685"; isCluster="true"; label="Exchange"; 333052 [id="node_333052" labelType="html" label="MapPartitionsRDD [333052] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 333045->333046; 333046->333047; 333047->333048; 333048->333049; 333049->333050; 333050->333051; 333051->333052; }

333044,333045

333047

digraph G { id="graph_1270691"; subgraph graph_stage_1270691 { id="graph_stage_1270691"; isCluster="true"; label="Stage 1270691"; subgraph cluster_856685 { id="cluster_856685"; isCluster="true"; label="Exchange"; 333053 [id="node_333053" labelType="html" label="ShuffledRowRDD [333053] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856682 { id="cluster_856682"; isCluster="true"; label="WholeStageCodegen (2)"; 333054 [id="node_333054" labelType="html" label="MapPartitionsRDD [333054] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_856698 { id="cluster_856698"; isCluster="true"; label="mapPartitionsInternal"; 333055 [id="node_333055" labelType="html" label="MapPartitionsRDD [333055] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 333053->333054; 333054->333055; }

333052,333053

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1270691	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 41 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:10:02	0.1 s	30/30	576.0 B
1270690	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 41 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:10:01	0.4 s	30/30	4.5 KiB	576.0 B
1270689	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 41 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:10:01	0.1 s	30/30	4.4 KiB	4.5 KiB
1270688	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 41 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:10:00	0.5 s	8/8		4.4 KiB

Page: