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

Status: SUCCEEDED
Submitted: 2026/05/20 06:03:37
Duration: 0.3 s
Associated SQL Query: 64233
Job Group: a916795f-b51b-4479-8bfc-bf20af3490c9
Completed Stages: 3

Enable zooming

digraph G { id="graph_277743"; subgraph graph_stage_277743 { id="graph_stage_277743"; isCluster="true"; label="Stage 277743"; 787100 [id="node_787100" labelType="html" label="SQLExecutionRDD [787100] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_1992528 { id="cluster_1992528"; isCluster="true"; label="Scan parquet "; 787097 [id="node_787097" labelType="html" label="FileScanRDD [787097] start at FileStorageAdapterImpl.java:174}"]; 787098 [id="node_787098" labelType="html" label="MapPartitionsRDD [787098] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992525 { id="cluster_1992525"; isCluster="true"; label="WholeStageCodegen (1)"; 787099 [id="node_787099" labelType="html" label="MapPartitionsRDD [787099] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992532 { id="cluster_1992532"; isCluster="true"; label="WholeStageCodegen (1)"; 787101 [id="node_787101" labelType="html" label="MapPartitionsRDD [787101] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992531 { id="cluster_1992531"; isCluster="true"; label="Exchange"; 787102 [id="node_787102" labelType="html" label="MapPartitionsRDD [787102] start at FileStorageAdapterImpl.java:174}"]; } } 787097->787098; 787098->787099; 787099->787100; 787100->787101; 787101->787102; }

digraph G { id="graph_277744"; subgraph graph_stage_277744 { id="graph_stage_277744"; isCluster="true"; label="Stage 277744"; subgraph cluster_1992531 { id="cluster_1992531"; isCluster="true"; label="Exchange"; 787103 [id="node_787103" labelType="html" label="ShuffledRowRDD [787103] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992530 { id="cluster_1992530"; isCluster="true"; label="InMemoryTableScan"; 787104 [id="node_787104" labelType="html" label="MapPartitionsRDD [787104] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 787105 [id="node_787105" labelType="html" label="Exchange hashpartitioning(product#13191129, plant#13191130, 30), REPARTITION_BY_NUM, [plan_id=13490877]\n+- *(1) Scan ExistingRDD[shardId#13191126,worklistShardItemId#13191127L,version#13191128,product#13191129,plant#13191130,periodStart#13191131,periodEnd#13191132,qty#13191133]\n [787105] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 787106 [id="node_787106" labelType="html" label="MapPartitionsRDD [787106] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 787107 [id="node_787107" labelType="html" label="MapPartitionsRDD [787107] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 787108 [id="node_787108" labelType="html" label="MapPartitionsRDD [787108] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992529 { id="cluster_1992529"; isCluster="true"; label="CollectLimit"; 787109 [id="node_787109" labelType="html" label="MapPartitionsRDD [787109] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 787110 [id="node_787110" labelType="html" label="MapPartitionsRDD [787110] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 787103->787104; 787104->787105; 787105->787106; 787106->787107; 787107->787108; 787108->787109; 787109->787110; }

787102,787103

787105

digraph G { id="graph_277745"; subgraph graph_stage_277745 { id="graph_stage_277745"; isCluster="true"; label="Stage 277745"; subgraph cluster_1992529 { id="cluster_1992529"; isCluster="true"; label="CollectLimit"; 787111 [id="node_787111" labelType="html" label="ShuffledRowRDD [787111] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 787112 [id="node_787112" labelType="html" label="MapPartitionsRDD [787112] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992534 { id="cluster_1992534"; isCluster="true"; label="mapPartitionsInternal"; 787113 [id="node_787113" labelType="html" label="MapPartitionsRDD [787113] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 787111->787112; 787112->787113; }

787110,787111

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
277745	tenants-pool-562	stream-10000000265-1 id = 42e25fc0-d8ad-4b61-b7c3-ee524eefadc3 runId = a916795f-b51b-4479-8bfc-bf20af3490c9 batch = 105 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor896.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:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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/20 06:03:38	6 ms	1/1
277744	tenants-pool-562	stream-10000000265-1 id = 42e25fc0-d8ad-4b61-b7c3-ee524eefadc3 runId = a916795f-b51b-4479-8bfc-bf20af3490c9 batch = 105 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor896.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:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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/20 06:03:38	26 ms	30/30	1152.0 B	248.0 B
277743	tenants-pool-562	stream-10000000265-1 id = 42e25fc0-d8ad-4b61-b7c3-ee524eefadc3 runId = a916795f-b51b-4479-8bfc-bf20af3490c9 batch = 105 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor896.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:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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/20 06:03:37	0.3 s	6/6		1152.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

277745

tenants-pool-562

stream-10000000265-1 id = 42e25fc0-d8ad-4b61-b7c3-ee524eefadc3 runId = a916795f-b51b-4479-8bfc-bf20af3490c9 batch = 105 start at FileStorageAdapterImpl.java:174 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
jdk.internal.reflect.GeneratedMethodAccessor896.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:294)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76)
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/20 06:03:38

6 ms

1/1

277744

tenants-pool-562

stream-10000000265-1 id = 42e25fc0-d8ad-4b61-b7c3-ee524eefadc3 runId = a916795f-b51b-4479-8bfc-bf20af3490c9 batch = 105 start at FileStorageAdapterImpl.java:174 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
jdk.internal.reflect.GeneratedMethodAccessor896.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:294)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76)
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/20 06:03:38

26 ms

30/30

1152.0 B

248.0 B

277743

tenants-pool-562

stream-10000000265-1 id = 42e25fc0-d8ad-4b61-b7c3-ee524eefadc3 runId = a916795f-b51b-4479-8bfc-bf20af3490c9 batch = 105 start at FileStorageAdapterImpl.java:174 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
jdk.internal.reflect.GeneratedMethodAccessor896.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:294)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76)
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/20 06:03:37

0.3 s

6/6

1152.0 B

Page: