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

Status: SUCCEEDED
Submitted: 2026/03/20 06:12:16
Duration: 0.8 s
Associated SQL Query: 3177
Job Group: 1bf8bf4d-82dd-4e25-8e77-025080b5dea7
Completed Stages: 2
Skipped Stages: 106

Event Timeline

Enable zooming

No DAG visualization information to display for job 5786

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
105570	tenants-pool-451	stream-10000000678-1 id = 577d104d-3939-4d5b-b4cf-e36fe46192c3 runId = 1bf8bf4d-82dd-4e25-8e77-025080b5dea7 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) 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: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/20 06:12:16	8 ms	1/1
105569	tenants-pool-451	stream-10000000678-1 id = 577d104d-3939-4d5b-b4cf-e36fe46192c3 runId = 1bf8bf4d-82dd-4e25-8e77-025080b5dea7 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) 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: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/20 06:12:16	0.8 s	111/111	27.5 KiB			1550.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

105570

tenants-pool-451

stream-10000000678-1 id = 577d104d-3939-4d5b-b4cf-e36fe46192c3 runId = 1bf8bf4d-82dd-4e25-8e77-025080b5dea7 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)
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: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/20 06:12:16

8 ms

1/1

105569

tenants-pool-451

stream-10000000678-1 id = 577d104d-3939-4d5b-b4cf-e36fe46192c3 runId = 1bf8bf4d-82dd-4e25-8e77-025080b5dea7 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)
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: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/20 06:12:16

0.8 s

111/111

27.5 KiB

1550.0 B

Page:

Skipped Stages (106)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
105568	Unknown +details Unknown	Unknown	Unknown	0/0
105567	Unknown +details Unknown	Unknown	Unknown	0/0
105566	Unknown +details Unknown	Unknown	Unknown	0/0
105565	Unknown +details Unknown	Unknown	Unknown	0/0
105564	Unknown +details Unknown	Unknown	Unknown	0/0
105563	Unknown +details Unknown	Unknown	Unknown	0/0
105562	Unknown +details Unknown	Unknown	Unknown	0/0
105561	Unknown +details Unknown	Unknown	Unknown	0/0
105560	Unknown +details Unknown	Unknown	Unknown	0/0
105559	Unknown +details Unknown	Unknown	Unknown	0/0
105558	Unknown +details Unknown	Unknown	Unknown	0/0
105557	Unknown +details Unknown	Unknown	Unknown	0/0
105556	Unknown +details Unknown	Unknown	Unknown	0/0
105555	Unknown +details Unknown	Unknown	Unknown	0/0
105554	Unknown +details Unknown	Unknown	Unknown	0/0
105553	Unknown +details Unknown	Unknown	Unknown	0/0
105552	Unknown +details Unknown	Unknown	Unknown	0/0
105551	Unknown +details Unknown	Unknown	Unknown	0/0
105550	Unknown +details Unknown	Unknown	Unknown	0/0
105549	Unknown +details Unknown	Unknown	Unknown	0/0
105548	Unknown +details Unknown	Unknown	Unknown	0/0
105547	Unknown +details Unknown	Unknown	Unknown	0/0
105546	Unknown +details Unknown	Unknown	Unknown	0/0
105545	Unknown +details Unknown	Unknown	Unknown	0/0
105544	Unknown +details Unknown	Unknown	Unknown	0/0
105543	Unknown +details Unknown	Unknown	Unknown	0/0
105542	Unknown +details Unknown	Unknown	Unknown	0/0
105541	Unknown +details Unknown	Unknown	Unknown	0/0
105540	Unknown +details Unknown	Unknown	Unknown	0/0
105539	Unknown +details Unknown	Unknown	Unknown	0/0
105538	Unknown +details Unknown	Unknown	Unknown	0/0
105537	Unknown +details Unknown	Unknown	Unknown	0/0
105536	Unknown +details Unknown	Unknown	Unknown	0/0
105535	Unknown +details Unknown	Unknown	Unknown	0/0
105534	Unknown +details Unknown	Unknown	Unknown	0/0
105533	Unknown +details Unknown	Unknown	Unknown	0/0
105532	Unknown +details Unknown	Unknown	Unknown	0/0
105531	Unknown +details Unknown	Unknown	Unknown	0/0
105530	Unknown +details Unknown	Unknown	Unknown	0/0
105529	Unknown +details Unknown	Unknown	Unknown	0/0
105528	Unknown +details Unknown	Unknown	Unknown	0/0
105527	Unknown +details Unknown	Unknown	Unknown	0/0
105526	Unknown +details Unknown	Unknown	Unknown	0/0
105525	Unknown +details Unknown	Unknown	Unknown	0/0
105524	Unknown +details Unknown	Unknown	Unknown	0/0
105523	Unknown +details Unknown	Unknown	Unknown	0/0
105522	Unknown +details Unknown	Unknown	Unknown	0/0
105521	Unknown +details Unknown	Unknown	Unknown	0/0
105520	Unknown +details Unknown	Unknown	Unknown	0/0
105519	Unknown +details Unknown	Unknown	Unknown	0/0
105518	Unknown +details Unknown	Unknown	Unknown	0/0
105517	Unknown +details Unknown	Unknown	Unknown	0/0
105516	Unknown +details Unknown	Unknown	Unknown	0/0
105515	Unknown +details Unknown	Unknown	Unknown	0/0
105514	Unknown +details Unknown	Unknown	Unknown	0/0
105513	Unknown +details Unknown	Unknown	Unknown	0/0
105512	Unknown +details Unknown	Unknown	Unknown	0/0
105511	Unknown +details Unknown	Unknown	Unknown	0/0
105510	Unknown +details Unknown	Unknown	Unknown	0/0
105509	Unknown +details Unknown	Unknown	Unknown	0/0
105508	Unknown +details Unknown	Unknown	Unknown	0/0
105507	Unknown +details Unknown	Unknown	Unknown	0/0
105506	Unknown +details Unknown	Unknown	Unknown	0/0
105505	Unknown +details Unknown	Unknown	Unknown	0/0
105504	Unknown +details Unknown	Unknown	Unknown	0/0
105503	Unknown +details Unknown	Unknown	Unknown	0/0
105502	Unknown +details Unknown	Unknown	Unknown	0/0
105501	Unknown +details Unknown	Unknown	Unknown	0/0
105500	Unknown +details Unknown	Unknown	Unknown	0/0
105499	Unknown +details Unknown	Unknown	Unknown	0/0
105498	Unknown +details Unknown	Unknown	Unknown	0/0
105497	Unknown +details Unknown	Unknown	Unknown	0/0
105496	Unknown +details Unknown	Unknown	Unknown	0/0
105495	Unknown +details Unknown	Unknown	Unknown	0/0
105494	Unknown +details Unknown	Unknown	Unknown	0/0
105493	Unknown +details Unknown	Unknown	Unknown	0/0
105492	Unknown +details Unknown	Unknown	Unknown	0/0
105491	Unknown +details Unknown	Unknown	Unknown	0/0
105490	Unknown +details Unknown	Unknown	Unknown	0/0
105489	Unknown +details Unknown	Unknown	Unknown	0/0
105488	Unknown +details Unknown	Unknown	Unknown	0/0
105487	Unknown +details Unknown	Unknown	Unknown	0/0
105486	Unknown +details Unknown	Unknown	Unknown	0/0
105485	Unknown +details Unknown	Unknown	Unknown	0/0
105484	Unknown +details Unknown	Unknown	Unknown	0/0
105483	Unknown +details Unknown	Unknown	Unknown	0/0
105482	Unknown +details Unknown	Unknown	Unknown	0/0
105481	Unknown +details Unknown	Unknown	Unknown	0/0
105480	Unknown +details Unknown	Unknown	Unknown	0/0
105479	Unknown +details Unknown	Unknown	Unknown	0/0
105478	Unknown +details Unknown	Unknown	Unknown	0/0
105477	Unknown +details Unknown	Unknown	Unknown	0/0
105476	Unknown +details Unknown	Unknown	Unknown	0/0
105475	Unknown +details Unknown	Unknown	Unknown	0/0
105474	Unknown +details Unknown	Unknown	Unknown	0/0
105473	Unknown +details Unknown	Unknown	Unknown	0/0
105472	Unknown +details Unknown	Unknown	Unknown	0/0
105471	Unknown +details Unknown	Unknown	Unknown	0/0
105470	Unknown +details Unknown	Unknown	Unknown	0/0
105469	Unknown +details Unknown	Unknown	Unknown	0/0

Page: