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

Status: SUCCEEDED
Submitted: 2026/03/21 01:10:50
Duration: 1 s
Associated SQL Query: 3543
Job Group: 81faa882-918e-4a51-b5e3-3a01a5c048df
Completed Stages: 3

Enable zooming

digraph G { id="graph_115888"; subgraph graph_stage_115888 { id="graph_stage_115888"; isCluster="true"; label="Stage 115888"; 55896 [id="node_55896" labelType="html" label="SQLExecutionRDD [55896] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_145323 { id="cluster_145323"; isCluster="true"; label="Scan parquet "; 55893 [id="node_55893" labelType="html" label="FileScanRDD [55893] start at FileStorageAdapterImpl.java:171}"]; 55894 [id="node_55894" labelType="html" label="MapPartitionsRDD [55894] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145320 { id="cluster_145320"; isCluster="true"; label="WholeStageCodegen (1)"; 55895 [id="node_55895" labelType="html" label="MapPartitionsRDD [55895] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145327 { id="cluster_145327"; isCluster="true"; label="WholeStageCodegen (1)"; 55897 [id="node_55897" labelType="html" label="MapPartitionsRDD [55897] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145326 { id="cluster_145326"; isCluster="true"; label="Exchange"; 55898 [id="node_55898" labelType="html" label="MapPartitionsRDD [55898] start at FileStorageAdapterImpl.java:171}"]; } } 55893->55894; 55894->55895; 55895->55896; 55896->55897; 55897->55898; }

digraph G { id="graph_115889"; subgraph graph_stage_115889 { id="graph_stage_115889"; isCluster="true"; label="Stage 115889"; subgraph cluster_145326 { id="cluster_145326"; isCluster="true"; label="Exchange"; 55899 [id="node_55899" labelType="html" label="ShuffledRowRDD [55899] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145325 { id="cluster_145325"; isCluster="true"; label="InMemoryTableScan"; 55900 [id="node_55900" labelType="html" label="MapPartitionsRDD [55900] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 55901 [id="node_55901" labelType="html" label="Exchange hashpartitioning(product#1100460, plant#1100461, 37), REPARTITION_BY_NUM, [plan_id=1753674]\n+- *(1) Scan ExistingRDD[shardId#1100457,worklistShardItemId#1100458L,version#1100459,product#1100460,plant#1100461,periodStart#1100462,periodEnd#1100463,qty#1100464]\n [55901] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 55902 [id="node_55902" labelType="html" label="MapPartitionsRDD [55902] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 55903 [id="node_55903" labelType="html" label="MapPartitionsRDD [55903] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 55904 [id="node_55904" labelType="html" label="MapPartitionsRDD [55904] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145324 { id="cluster_145324"; isCluster="true"; label="CollectLimit"; 55905 [id="node_55905" labelType="html" label="MapPartitionsRDD [55905] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 55906 [id="node_55906" labelType="html" label="MapPartitionsRDD [55906] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 55899->55900; 55900->55901; 55901->55902; 55902->55903; 55903->55904; 55904->55905; 55905->55906; }

55898,55899

55901

digraph G { id="graph_115890"; subgraph graph_stage_115890 { id="graph_stage_115890"; isCluster="true"; label="Stage 115890"; subgraph cluster_145324 { id="cluster_145324"; isCluster="true"; label="CollectLimit"; 55907 [id="node_55907" labelType="html" label="ShuffledRowRDD [55907] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 55908 [id="node_55908" labelType="html" label="MapPartitionsRDD [55908] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145329 { id="cluster_145329"; isCluster="true"; label="mapPartitionsInternal"; 55909 [id="node_55909" labelType="html" label="MapPartitionsRDD [55909] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 55907->55908; 55908->55909; }

55906,55907

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
115890	tenants-pool-780	stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 3 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:10:51	7 ms	1/1
115889	tenants-pool-780	stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 3 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:10:51	0.9 s	37/37	13.7 KiB	1860.0 B
115888	tenants-pool-780	stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 3 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:10:50	0.3 s	6/6		13.7 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

115890

tenants-pool-780

stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 3 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:10:51

7 ms

1/1

115889

tenants-pool-780

stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 3 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:10:51

0.9 s

37/37

13.7 KiB

1860.0 B

115888

tenants-pool-780

stream-10000000350-1 id = dc642002-2b52-4744-bf90-967729f330bc runId = 81faa882-918e-4a51-b5e3-3a01a5c048df batch = 3 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:10:50

0.3 s

6/6

13.7 KiB

Page: