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

Status: SUCCEEDED
Submitted: 2026/03/21 01:19:15
Duration: 0.4 s
Associated SQL Query: 3627
Job Group: 81faa882-918e-4a51-b5e3-3a01a5c048df
Completed Stages: 3

Enable zooming

digraph G { id="graph_118606"; subgraph graph_stage_118606 { id="graph_stage_118606"; isCluster="true"; label="Stage 118606"; 57482 [id="node_57482" labelType="html" label="SQLExecutionRDD [57482] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_149051 { id="cluster_149051"; isCluster="true"; label="Scan parquet "; 57479 [id="node_57479" labelType="html" label="FileScanRDD [57479] start at FileStorageAdapterImpl.java:171}"]; 57480 [id="node_57480" labelType="html" label="MapPartitionsRDD [57480] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149048 { id="cluster_149048"; isCluster="true"; label="WholeStageCodegen (1)"; 57481 [id="node_57481" labelType="html" label="MapPartitionsRDD [57481] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149055 { id="cluster_149055"; isCluster="true"; label="WholeStageCodegen (1)"; 57483 [id="node_57483" labelType="html" label="MapPartitionsRDD [57483] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149054 { id="cluster_149054"; isCluster="true"; label="Exchange"; 57484 [id="node_57484" labelType="html" label="MapPartitionsRDD [57484] start at FileStorageAdapterImpl.java:171}"]; } } 57479->57480; 57480->57481; 57481->57482; 57482->57483; 57483->57484; }

digraph G { id="graph_118607"; subgraph graph_stage_118607 { id="graph_stage_118607"; isCluster="true"; label="Stage 118607"; subgraph cluster_149054 { id="cluster_149054"; isCluster="true"; label="Exchange"; 57485 [id="node_57485" labelType="html" label="ShuffledRowRDD [57485] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149053 { id="cluster_149053"; isCluster="true"; label="InMemoryTableScan"; 57486 [id="node_57486" labelType="html" label="MapPartitionsRDD [57486] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 57487 [id="node_57487" labelType="html" label="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1763158]\n+- *(1) Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]\n [57487] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 57488 [id="node_57488" labelType="html" label="MapPartitionsRDD [57488] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 57489 [id="node_57489" labelType="html" label="MapPartitionsRDD [57489] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 57490 [id="node_57490" labelType="html" label="MapPartitionsRDD [57490] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149052 { id="cluster_149052"; isCluster="true"; label="CollectLimit"; 57491 [id="node_57491" labelType="html" label="MapPartitionsRDD [57491] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 57492 [id="node_57492" labelType="html" label="MapPartitionsRDD [57492] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 57485->57486; 57486->57487; 57487->57488; 57488->57489; 57489->57490; 57490->57491; 57491->57492; }

57484,57485

57487

digraph G { id="graph_118608"; subgraph graph_stage_118608 { id="graph_stage_118608"; isCluster="true"; label="Stage 118608"; subgraph cluster_149052 { id="cluster_149052"; isCluster="true"; label="CollectLimit"; 57493 [id="node_57493" labelType="html" label="ShuffledRowRDD [57493] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 57494 [id="node_57494" labelType="html" label="MapPartitionsRDD [57494] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149057 { id="cluster_149057"; isCluster="true"; label="mapPartitionsInternal"; 57495 [id="node_57495" labelType="html" label="MapPartitionsRDD [57495] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 57493->57494; 57494->57495; }

57492,57493

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
118608	tenants-pool-780	stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 9 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) jdk.internal.reflect.GeneratedMethodAccessor1635.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/03/21 01:19:16	6 ms	1/1
118607	tenants-pool-780	stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 9 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) jdk.internal.reflect.GeneratedMethodAccessor1635.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/03/21 01:19:16	31 ms	37/37	1463.0 B	434.0 B
118606	tenants-pool-780	stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 9 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) jdk.internal.reflect.GeneratedMethodAccessor1635.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/03/21 01:19:15	0.3 s	5/5		1463.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

118608

tenants-pool-780

stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 9 start at FileStorageAdapterImpl.java:171 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63)
jdk.internal.reflect.GeneratedMethodAccessor1635.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/03/21 01:19:16

6 ms

1/1

118607

tenants-pool-780

stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 9 start at FileStorageAdapterImpl.java:171 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63)
jdk.internal.reflect.GeneratedMethodAccessor1635.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/03/21 01:19:16

31 ms

37/37

1463.0 B

434.0 B

118606

tenants-pool-780

stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 9 start at FileStorageAdapterImpl.java:171 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63)
jdk.internal.reflect.GeneratedMethodAccessor1635.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/03/21 01:19:15

0.3 s

5/5

1463.0 B

Page: