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

Status: SUCCEEDED
Submitted: 2026/03/20 06:09:54
Duration: 0.5 s
Associated SQL Query: 3160
Job Group: 1bf8bf4d-82dd-4e25-8e77-025080b5dea7
Completed Stages: 2
Skipped Stages: 78

Event Timeline

Enable zooming

No DAG visualization information to display for job 5760

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
104184	tenants-pool-451	stream-10000000678-1 id = 577d104d-3939-4d5b-b4cf-e36fe46192c3 runId = 1bf8bf4d-82dd-4e25-8e77-025080b5dea7 batch = 8 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:09:54	0.2 s	37/37			13.4 KiB
104183	tenants-pool-451	stream-10000000678-1 id = 577d104d-3939-4d5b-b4cf-e36fe46192c3 runId = 1bf8bf4d-82dd-4e25-8e77-025080b5dea7 batch = 8 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:09:54	0.3 s	74/74	15.3 KiB			13.4 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

104184

tenants-pool-451

stream-10000000678-1 id = 577d104d-3939-4d5b-b4cf-e36fe46192c3 runId = 1bf8bf4d-82dd-4e25-8e77-025080b5dea7 batch = 8 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:09:54

0.2 s

37/37

13.4 KiB

104183

tenants-pool-451

stream-10000000678-1 id = 577d104d-3939-4d5b-b4cf-e36fe46192c3 runId = 1bf8bf4d-82dd-4e25-8e77-025080b5dea7 batch = 8 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:09:54

0.3 s

74/74

15.3 KiB

13.4 KiB

Page:

Skipped Stages (78)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
104182	Unknown +details Unknown	Unknown	Unknown	0/0
104181	Unknown +details Unknown	Unknown	Unknown	0/0
104180	Unknown +details Unknown	Unknown	Unknown	0/0
104179	Unknown +details Unknown	Unknown	Unknown	0/0
104178	Unknown +details Unknown	Unknown	Unknown	0/0
104177	Unknown +details Unknown	Unknown	Unknown	0/0
104176	Unknown +details Unknown	Unknown	Unknown	0/0
104175	Unknown +details Unknown	Unknown	Unknown	0/0
104174	Unknown +details Unknown	Unknown	Unknown	0/0
104173	Unknown +details Unknown	Unknown	Unknown	0/0
104172	Unknown +details Unknown	Unknown	Unknown	0/0
104171	Unknown +details Unknown	Unknown	Unknown	0/0
104170	Unknown +details Unknown	Unknown	Unknown	0/0
104169	Unknown +details Unknown	Unknown	Unknown	0/0
104168	Unknown +details Unknown	Unknown	Unknown	0/0
104167	Unknown +details Unknown	Unknown	Unknown	0/0
104166	Unknown +details Unknown	Unknown	Unknown	0/0
104165	Unknown +details Unknown	Unknown	Unknown	0/0
104164	Unknown +details Unknown	Unknown	Unknown	0/0
104163	Unknown +details Unknown	Unknown	Unknown	0/0
104162	Unknown +details Unknown	Unknown	Unknown	0/0
104161	Unknown +details Unknown	Unknown	Unknown	0/0
104160	Unknown +details Unknown	Unknown	Unknown	0/0
104159	Unknown +details Unknown	Unknown	Unknown	0/0
104158	Unknown +details Unknown	Unknown	Unknown	0/0
104157	Unknown +details Unknown	Unknown	Unknown	0/0
104156	Unknown +details Unknown	Unknown	Unknown	0/0
104155	Unknown +details Unknown	Unknown	Unknown	0/0
104154	Unknown +details Unknown	Unknown	Unknown	0/0
104153	Unknown +details Unknown	Unknown	Unknown	0/0
104152	Unknown +details Unknown	Unknown	Unknown	0/0
104151	Unknown +details Unknown	Unknown	Unknown	0/0
104150	Unknown +details Unknown	Unknown	Unknown	0/0
104149	Unknown +details Unknown	Unknown	Unknown	0/0
104148	Unknown +details Unknown	Unknown	Unknown	0/0
104147	Unknown +details Unknown	Unknown	Unknown	0/0
104146	Unknown +details Unknown	Unknown	Unknown	0/0
104145	Unknown +details Unknown	Unknown	Unknown	0/0
104144	Unknown +details Unknown	Unknown	Unknown	0/0
104143	Unknown +details Unknown	Unknown	Unknown	0/0
104142	Unknown +details Unknown	Unknown	Unknown	0/0
104141	Unknown +details Unknown	Unknown	Unknown	0/0
104140	Unknown +details Unknown	Unknown	Unknown	0/0
104139	Unknown +details Unknown	Unknown	Unknown	0/0
104138	Unknown +details Unknown	Unknown	Unknown	0/0
104137	Unknown +details Unknown	Unknown	Unknown	0/0
104136	Unknown +details Unknown	Unknown	Unknown	0/0
104135	Unknown +details Unknown	Unknown	Unknown	0/0
104134	Unknown +details Unknown	Unknown	Unknown	0/0
104133	Unknown +details Unknown	Unknown	Unknown	0/0
104132	Unknown +details Unknown	Unknown	Unknown	0/0
104131	Unknown +details Unknown	Unknown	Unknown	0/0
104130	Unknown +details Unknown	Unknown	Unknown	0/0
104129	Unknown +details Unknown	Unknown	Unknown	0/0
104128	Unknown +details Unknown	Unknown	Unknown	0/0
104127	Unknown +details Unknown	Unknown	Unknown	0/0
104126	Unknown +details Unknown	Unknown	Unknown	0/0
104125	Unknown +details Unknown	Unknown	Unknown	0/0
104124	Unknown +details Unknown	Unknown	Unknown	0/0
104123	Unknown +details Unknown	Unknown	Unknown	0/0
104122	Unknown +details Unknown	Unknown	Unknown	0/0
104121	Unknown +details Unknown	Unknown	Unknown	0/0
104120	Unknown +details Unknown	Unknown	Unknown	0/0
104119	Unknown +details Unknown	Unknown	Unknown	0/0
104118	Unknown +details Unknown	Unknown	Unknown	0/0
104117	Unknown +details Unknown	Unknown	Unknown	0/0
104116	Unknown +details Unknown	Unknown	Unknown	0/0
104115	Unknown +details Unknown	Unknown	Unknown	0/0
104114	Unknown +details Unknown	Unknown	Unknown	0/0
104113	Unknown +details Unknown	Unknown	Unknown	0/0
104112	Unknown +details Unknown	Unknown	Unknown	0/0
104111	Unknown +details Unknown	Unknown	Unknown	0/0
104110	Unknown +details Unknown	Unknown	Unknown	0/0
104109	Unknown +details Unknown	Unknown	Unknown	0/0
104108	Unknown +details Unknown	Unknown	Unknown	0/0
104107	Unknown +details Unknown	Unknown	Unknown	0/0
104106	Unknown +details Unknown	Unknown	Unknown	0/0
104105	Unknown +details Unknown	Unknown	Unknown	0/0

Page: