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

Status: SUCCEEDED
Submitted: 2026/03/20 06:08:30
Duration: 1 s
Associated SQL Query: 3139
Job Group: 1bf8bf4d-82dd-4e25-8e77-025080b5dea7
Completed Stages: 2
Skipped Stages: 69

Event Timeline

Enable zooming

No DAG visualization information to display for job 5740

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
103561	tenants-pool-451	stream-10000000678-1 id = 577d104d-3939-4d5b-b4cf-e36fe46192c3 runId = 1bf8bf4d-82dd-4e25-8e77-025080b5dea7 batch = 7 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:08:30	0.5 s	37/37			41.8 KiB
103560	tenants-pool-451	stream-10000000678-1 id = 577d104d-3939-4d5b-b4cf-e36fe46192c3 runId = 1bf8bf4d-82dd-4e25-8e77-025080b5dea7 batch = 7 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:08:30	0.7 s	111/111	91.1 KiB			41.8 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

103561

tenants-pool-451

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

0.5 s

37/37

41.8 KiB

103560

tenants-pool-451

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

0.7 s

111/111

91.1 KiB

41.8 KiB

Page:

Skipped Stages (69)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
103559	Unknown +details Unknown	Unknown	Unknown	0/0
103558	Unknown +details Unknown	Unknown	Unknown	0/0
103557	Unknown +details Unknown	Unknown	Unknown	0/0
103556	Unknown +details Unknown	Unknown	Unknown	0/0
103555	Unknown +details Unknown	Unknown	Unknown	0/0
103554	Unknown +details Unknown	Unknown	Unknown	0/0
103553	Unknown +details Unknown	Unknown	Unknown	0/0
103552	Unknown +details Unknown	Unknown	Unknown	0/0
103551	Unknown +details Unknown	Unknown	Unknown	0/0
103550	Unknown +details Unknown	Unknown	Unknown	0/0
103549	Unknown +details Unknown	Unknown	Unknown	0/0
103548	Unknown +details Unknown	Unknown	Unknown	0/0
103547	Unknown +details Unknown	Unknown	Unknown	0/0
103546	Unknown +details Unknown	Unknown	Unknown	0/0
103545	Unknown +details Unknown	Unknown	Unknown	0/0
103544	Unknown +details Unknown	Unknown	Unknown	0/0
103543	Unknown +details Unknown	Unknown	Unknown	0/0
103542	Unknown +details Unknown	Unknown	Unknown	0/0
103541	Unknown +details Unknown	Unknown	Unknown	0/0
103540	Unknown +details Unknown	Unknown	Unknown	0/0
103539	Unknown +details Unknown	Unknown	Unknown	0/0
103538	Unknown +details Unknown	Unknown	Unknown	0/0
103537	Unknown +details Unknown	Unknown	Unknown	0/0
103536	Unknown +details Unknown	Unknown	Unknown	0/0
103535	Unknown +details Unknown	Unknown	Unknown	0/0
103534	Unknown +details Unknown	Unknown	Unknown	0/0
103533	Unknown +details Unknown	Unknown	Unknown	0/0
103532	Unknown +details Unknown	Unknown	Unknown	0/0
103531	Unknown +details Unknown	Unknown	Unknown	0/0
103530	Unknown +details Unknown	Unknown	Unknown	0/0
103529	Unknown +details Unknown	Unknown	Unknown	0/0
103528	Unknown +details Unknown	Unknown	Unknown	0/0
103527	Unknown +details Unknown	Unknown	Unknown	0/0
103526	Unknown +details Unknown	Unknown	Unknown	0/0
103525	Unknown +details Unknown	Unknown	Unknown	0/0
103524	Unknown +details Unknown	Unknown	Unknown	0/0
103523	Unknown +details Unknown	Unknown	Unknown	0/0
103522	Unknown +details Unknown	Unknown	Unknown	0/0
103521	Unknown +details Unknown	Unknown	Unknown	0/0
103520	Unknown +details Unknown	Unknown	Unknown	0/0
103519	Unknown +details Unknown	Unknown	Unknown	0/0
103518	Unknown +details Unknown	Unknown	Unknown	0/0
103517	Unknown +details Unknown	Unknown	Unknown	0/0
103516	Unknown +details Unknown	Unknown	Unknown	0/0
103515	Unknown +details Unknown	Unknown	Unknown	0/0
103514	Unknown +details Unknown	Unknown	Unknown	0/0
103513	Unknown +details Unknown	Unknown	Unknown	0/0
103512	Unknown +details Unknown	Unknown	Unknown	0/0
103511	Unknown +details Unknown	Unknown	Unknown	0/0
103510	Unknown +details Unknown	Unknown	Unknown	0/0
103509	Unknown +details Unknown	Unknown	Unknown	0/0
103508	Unknown +details Unknown	Unknown	Unknown	0/0
103507	Unknown +details Unknown	Unknown	Unknown	0/0
103506	Unknown +details Unknown	Unknown	Unknown	0/0
103505	Unknown +details Unknown	Unknown	Unknown	0/0
103504	Unknown +details Unknown	Unknown	Unknown	0/0
103503	Unknown +details Unknown	Unknown	Unknown	0/0
103502	Unknown +details Unknown	Unknown	Unknown	0/0
103501	Unknown +details Unknown	Unknown	Unknown	0/0
103500	Unknown +details Unknown	Unknown	Unknown	0/0
103499	Unknown +details Unknown	Unknown	Unknown	0/0
103498	Unknown +details Unknown	Unknown	Unknown	0/0
103497	Unknown +details Unknown	Unknown	Unknown	0/0
103496	Unknown +details Unknown	Unknown	Unknown	0/0
103495	Unknown +details Unknown	Unknown	Unknown	0/0
103494	Unknown +details Unknown	Unknown	Unknown	0/0
103493	Unknown +details Unknown	Unknown	Unknown	0/0
103492	Unknown +details Unknown	Unknown	Unknown	0/0
103491	Unknown +details Unknown	Unknown	Unknown	0/0

Page: