crp-order-quantity-kpi-service - Details for Job 232

Status: SUCCEEDED
Submitted: 2026/08/10 08:18:45
Duration: 0.8 s
Associated SQL Query: 105
Job Group: f6fc2d63-a255-4383-a46a-6581aeff922a
Completed Stages: 3

Enable zooming

digraph G { id="graph_691"; subgraph graph_stage_691 { id="graph_stage_691"; isCluster="true"; label="Stage 691"; 1191 [id="node_1191" labelType="html" label="SQLExecutionRDD [1191] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_3001 { id="cluster_3001"; isCluster="true"; label="Scan parquet "; 1188 [id="node_1188" labelType="html" label="FileScanRDD [1188] start at FileStorageAdapterImpl.java:177}"]; 1189 [id="node_1189" labelType="html" label="MapPartitionsRDD [1189] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_2998 { id="cluster_2998"; isCluster="true"; label="WholeStageCodegen (1)"; 1190 [id="node_1190" labelType="html" label="MapPartitionsRDD [1190] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3005 { id="cluster_3005"; isCluster="true"; label="WholeStageCodegen (1)"; 1192 [id="node_1192" labelType="html" label="MapPartitionsRDD [1192] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3004 { id="cluster_3004"; isCluster="true"; label="Exchange"; 1193 [id="node_1193" labelType="html" label="MapPartitionsRDD [1193] start at FileStorageAdapterImpl.java:177}"]; } } 1188->1189; 1189->1190; 1190->1191; 1191->1192; 1192->1193; }

digraph G { id="graph_692"; subgraph graph_stage_692 { id="graph_stage_692"; isCluster="true"; label="Stage 692"; subgraph cluster_3004 { id="cluster_3004"; isCluster="true"; label="Exchange"; 1194 [id="node_1194" labelType="html" label="ShuffledRowRDD [1194] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3003 { id="cluster_3003"; isCluster="true"; label="InMemoryTableScan"; 1195 [id="node_1195" labelType="html" label="MapPartitionsRDD [1195] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1196 [id="node_1196" labelType="html" label="Exchange hashpartitioning(product#11, plant#12, 20), REPARTITION_BY_NUM, [plan_id=7741]\n+- *(1) Scan ExistingRDD[shardId#8,worklistShardItemId#9L,version#10,product#11,plant#12,periodStart#13,periodEnd#14,qty#15]\n [1196] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1197 [id="node_1197" labelType="html" label="MapPartitionsRDD [1197] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1198 [id="node_1198" labelType="html" label="MapPartitionsRDD [1198] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1199 [id="node_1199" labelType="html" label="MapPartitionsRDD [1199] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3002 { id="cluster_3002"; isCluster="true"; label="CollectLimit"; 1200 [id="node_1200" labelType="html" label="MapPartitionsRDD [1200] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1201 [id="node_1201" labelType="html" label="MapPartitionsRDD [1201] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1194->1195; 1195->1196; 1196->1197; 1197->1198; 1198->1199; 1199->1200; 1200->1201; }

1193,1194

1196

digraph G { id="graph_693"; subgraph graph_stage_693 { id="graph_stage_693"; isCluster="true"; label="Stage 693"; subgraph cluster_3002 { id="cluster_3002"; isCluster="true"; label="CollectLimit"; 1202 [id="node_1202" labelType="html" label="ShuffledRowRDD [1202] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1203 [id="node_1203" labelType="html" label="MapPartitionsRDD [1203] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_3007 { id="cluster_3007"; isCluster="true"; label="mapPartitionsInternal"; 1204 [id="node_1204" labelType="html" label="MapPartitionsRDD [1204] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1202->1203; 1203->1204; }

1201,1202

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
693	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 5 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/08/10 08:18:46	6 ms	1/1
692	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 5 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/08/10 08:18:45	0.4 s	20/20	128.1 KiB	1240.0 B
691	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 5 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/08/10 08:18:45	0.3 s	25/25		128.1 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

693

tenants-pool-286

stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 5 start at FileStorageAdapterImpl.java:177 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
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/08/10 08:18:46

6 ms

1/1

692

tenants-pool-286

stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 5 start at FileStorageAdapterImpl.java:177 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
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/08/10 08:18:45

0.4 s

20/20

128.1 KiB

1240.0 B

691

tenants-pool-286

stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 5 start at FileStorageAdapterImpl.java:177 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
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/08/10 08:18:45

0.3 s

25/25

128.1 KiB

Page: