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

Status: SUCCEEDED
Submitted: 2026/08/31 14:15:01
Duration: 6 s
Associated SQL Query: 32403
Job Group: 7c0d0c10-02f7-4ce6-8673-3f93ddb1bfa1
Completed Stages: 3

Enable zooming

digraph G { id="graph_190998"; subgraph graph_stage_190998 { id="graph_stage_190998"; isCluster="true"; label="Stage 190998"; 425622 [id="node_425622" labelType="html" label="SQLExecutionRDD [425622] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1112198 { id="cluster_1112198"; isCluster="true"; label="Scan parquet "; 425619 [id="node_425619" labelType="html" label="FileScanRDD [425619] start at FileStorageAdapterImpl.java:179}"]; 425620 [id="node_425620" labelType="html" label="MapPartitionsRDD [425620] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112195 { id="cluster_1112195"; isCluster="true"; label="WholeStageCodegen (1)"; 425621 [id="node_425621" labelType="html" label="MapPartitionsRDD [425621] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112202 { id="cluster_1112202"; isCluster="true"; label="WholeStageCodegen (1)"; 425623 [id="node_425623" labelType="html" label="MapPartitionsRDD [425623] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112201 { id="cluster_1112201"; isCluster="true"; label="Exchange"; 425624 [id="node_425624" labelType="html" label="MapPartitionsRDD [425624] start at FileStorageAdapterImpl.java:179}"]; } } 425619->425620; 425620->425621; 425621->425622; 425622->425623; 425623->425624; }

digraph G { id="graph_190999"; subgraph graph_stage_190999 { id="graph_stage_190999"; isCluster="true"; label="Stage 190999"; subgraph cluster_1112201 { id="cluster_1112201"; isCluster="true"; label="Exchange"; 425625 [id="node_425625" labelType="html" label="ShuffledRowRDD [425625] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112200 { id="cluster_1112200"; isCluster="true"; label="InMemoryTableScan"; 425626 [id="node_425626" labelType="html" label="MapPartitionsRDD [425626] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425627 [id="node_425627" labelType="html" label="Exchange hashpartitioning(product#6552476, plant#6552477, 30), REPARTITION_BY_NUM, [plan_id=29065369]\n+- *(1) Scan ExistingRDD[shardId#6552473,worklistShardItemId#6552474L,version#6552475,product#6552476,plant#6552477,periodStart#6552478,periodEnd#6552479,qty#6552480]\n [425627] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425628 [id="node_425628" labelType="html" label="MapPartitionsRDD [425628] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425629 [id="node_425629" labelType="html" label="MapPartitionsRDD [425629] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425630 [id="node_425630" labelType="html" label="MapPartitionsRDD [425630] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112199 { id="cluster_1112199"; isCluster="true"; label="CollectLimit"; 425631 [id="node_425631" labelType="html" label="MapPartitionsRDD [425631] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425632 [id="node_425632" labelType="html" label="MapPartitionsRDD [425632] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 425625->425626; 425626->425627; 425627->425628; 425628->425629; 425629->425630; 425630->425631; 425631->425632; }

425624,425625

425627

digraph G { id="graph_191000"; subgraph graph_stage_191000 { id="graph_stage_191000"; isCluster="true"; label="Stage 191000"; subgraph cluster_1112199 { id="cluster_1112199"; isCluster="true"; label="CollectLimit"; 425633 [id="node_425633" labelType="html" label="ShuffledRowRDD [425633] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425634 [id="node_425634" labelType="html" label="MapPartitionsRDD [425634] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112204 { id="cluster_1112204"; isCluster="true"; label="mapPartitionsInternal"; 425635 [id="node_425635" labelType="html" label="MapPartitionsRDD [425635] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 425633->425634; 425634->425635; }

425632,425633

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
191000	tenants-pool-506	stream-10000000532-1 id = 45b8c589-8057-4cad-ad92-e5e16b94fd0f runId = 7c0d0c10-02f7-4ce6-8673-3f93ddb1bfa1 batch = 20 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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/31 14:15:07	5 ms	1/1
190999	tenants-pool-506	stream-10000000532-1 id = 45b8c589-8057-4cad-ad92-e5e16b94fd0f runId = 7c0d0c10-02f7-4ce6-8673-3f93ddb1bfa1 batch = 20 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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/31 14:15:02	0.7 s	30/30	2.1 MiB	1860.0 B
190998	tenants-pool-506	stream-10000000532-1 id = 45b8c589-8057-4cad-ad92-e5e16b94fd0f runId = 7c0d0c10-02f7-4ce6-8673-3f93ddb1bfa1 batch = 20 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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/31 14:15:01	0.9 s	37/37		2.1 MiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

191000

tenants-pool-506

stream-10000000532-1 id = 45b8c589-8057-4cad-ad92-e5e16b94fd0f runId = 7c0d0c10-02f7-4ce6-8673-3f93ddb1bfa1 batch = 20 start at FileStorageAdapterImpl.java:179 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
jdk.internal.reflect.GeneratedMethodAccessor984.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/31 14:15:07

5 ms

1/1

190999

tenants-pool-506

stream-10000000532-1 id = 45b8c589-8057-4cad-ad92-e5e16b94fd0f runId = 7c0d0c10-02f7-4ce6-8673-3f93ddb1bfa1 batch = 20 start at FileStorageAdapterImpl.java:179 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
jdk.internal.reflect.GeneratedMethodAccessor984.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/31 14:15:02

0.7 s

30/30

2.1 MiB

1860.0 B

190998

tenants-pool-506

stream-10000000532-1 id = 45b8c589-8057-4cad-ad92-e5e16b94fd0f runId = 7c0d0c10-02f7-4ce6-8673-3f93ddb1bfa1 batch = 20 start at FileStorageAdapterImpl.java:179 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
jdk.internal.reflect.GeneratedMethodAccessor984.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/31 14:15:01

0.9 s

37/37

2.1 MiB

Page: