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

Status: SUCCEEDED
Submitted: 2026/03/20 20:12:36
Duration: 2 s
Associated SQL Query: 3349
Job Group: 1785dd42-a3bd-40d2-8e91-765a57162f64
Completed Stages: 7
Skipped Stages: 127

Enable zooming

No DAG visualization information to display for job 6067

Completed Stages (7)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Shuffle Read	Shuffle Write
110533	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 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 20:12:38	0.2 s	37/37		300.0 B
110532	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 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 20:12:37	1 s	74/74	777.0 B	708.0 B	300.0 B
110531	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 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 20:12:37	0.4 s	74/74	60.3 KiB	56.0 KiB
110530	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 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 20:12:36	0.3 s	37/37	1518.0 B		708.0 B
110529	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 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 20:12:36	0.3 s	37/37	60.3 KiB		151.7 KiB
110528	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 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 20:12:37	0.3 s	37/37
110527	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 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 20:12:36	0.3 s	37/37	60.3 KiB

Page:

Skipped Stages (127)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
110526	Unknown +details Unknown	Unknown	Unknown	0/0
110525	Unknown +details Unknown	Unknown	Unknown	0/0
110524	Unknown +details Unknown	Unknown	Unknown	0/0
110523	Unknown +details Unknown	Unknown	Unknown	0/0
110522	Unknown +details Unknown	Unknown	Unknown	0/0
110521	Unknown +details Unknown	Unknown	Unknown	0/0
110520	Unknown +details Unknown	Unknown	Unknown	0/0
110519	Unknown +details Unknown	Unknown	Unknown	0/0
110518	Unknown +details Unknown	Unknown	Unknown	0/0
110517	Unknown +details Unknown	Unknown	Unknown	0/0
110516	Unknown +details Unknown	Unknown	Unknown	0/0
110515	Unknown +details Unknown	Unknown	Unknown	0/0
110514	Unknown +details Unknown	Unknown	Unknown	0/0
110513	Unknown +details Unknown	Unknown	Unknown	0/0
110512	Unknown +details Unknown	Unknown	Unknown	0/0
110511	Unknown +details Unknown	Unknown	Unknown	0/0
110510	Unknown +details Unknown	Unknown	Unknown	0/0
110509	Unknown +details Unknown	Unknown	Unknown	0/0
110508	Unknown +details Unknown	Unknown	Unknown	0/0
110507	Unknown +details Unknown	Unknown	Unknown	0/0
110506	Unknown +details Unknown	Unknown	Unknown	0/0
110505	Unknown +details Unknown	Unknown	Unknown	0/0
110504	Unknown +details Unknown	Unknown	Unknown	0/0
110503	Unknown +details Unknown	Unknown	Unknown	0/0
110502	Unknown +details Unknown	Unknown	Unknown	0/0
110501	Unknown +details Unknown	Unknown	Unknown	0/0
110500	Unknown +details Unknown	Unknown	Unknown	0/0
110499	Unknown +details Unknown	Unknown	Unknown	0/0
110498	Unknown +details Unknown	Unknown	Unknown	0/0
110497	Unknown +details Unknown	Unknown	Unknown	0/0
110496	Unknown +details Unknown	Unknown	Unknown	0/0
110495	Unknown +details Unknown	Unknown	Unknown	0/0
110494	Unknown +details Unknown	Unknown	Unknown	0/0
110493	Unknown +details Unknown	Unknown	Unknown	0/0
110492	Unknown +details Unknown	Unknown	Unknown	0/0
110491	Unknown +details Unknown	Unknown	Unknown	0/0
110490	Unknown +details Unknown	Unknown	Unknown	0/0
110489	Unknown +details Unknown	Unknown	Unknown	0/0
110488	Unknown +details Unknown	Unknown	Unknown	0/0
110487	Unknown +details Unknown	Unknown	Unknown	0/0
110486	Unknown +details Unknown	Unknown	Unknown	0/0
110485	Unknown +details Unknown	Unknown	Unknown	0/0
110484	Unknown +details Unknown	Unknown	Unknown	0/0
110483	Unknown +details Unknown	Unknown	Unknown	0/0
110482	Unknown +details Unknown	Unknown	Unknown	0/0
110481	Unknown +details Unknown	Unknown	Unknown	0/0
110480	Unknown +details Unknown	Unknown	Unknown	0/0
110479	Unknown +details Unknown	Unknown	Unknown	0/0
110478	Unknown +details Unknown	Unknown	Unknown	0/0
110477	Unknown +details Unknown	Unknown	Unknown	0/0
110476	Unknown +details Unknown	Unknown	Unknown	0/0
110475	Unknown +details Unknown	Unknown	Unknown	0/0
110474	Unknown +details Unknown	Unknown	Unknown	0/0
110473	Unknown +details Unknown	Unknown	Unknown	0/0
110472	Unknown +details Unknown	Unknown	Unknown	0/0
110471	Unknown +details Unknown	Unknown	Unknown	0/0
110470	Unknown +details Unknown	Unknown	Unknown	0/0
110469	Unknown +details Unknown	Unknown	Unknown	0/0
110468	Unknown +details Unknown	Unknown	Unknown	0/0
110467	Unknown +details Unknown	Unknown	Unknown	0/0
110466	Unknown +details Unknown	Unknown	Unknown	0/0
110465	Unknown +details Unknown	Unknown	Unknown	0/0
110464	Unknown +details Unknown	Unknown	Unknown	0/0
110463	Unknown +details Unknown	Unknown	Unknown	0/0
110462	Unknown +details Unknown	Unknown	Unknown	0/0
110461	Unknown +details Unknown	Unknown	Unknown	0/0
110460	Unknown +details Unknown	Unknown	Unknown	0/0
110459	Unknown +details Unknown	Unknown	Unknown	0/0
110458	Unknown +details Unknown	Unknown	Unknown	0/0
110457	Unknown +details Unknown	Unknown	Unknown	0/0
110456	Unknown +details Unknown	Unknown	Unknown	0/0
110455	Unknown +details Unknown	Unknown	Unknown	0/0
110454	Unknown +details Unknown	Unknown	Unknown	0/0
110453	Unknown +details Unknown	Unknown	Unknown	0/0
110452	Unknown +details Unknown	Unknown	Unknown	0/0
110451	Unknown +details Unknown	Unknown	Unknown	0/0
110450	Unknown +details Unknown	Unknown	Unknown	0/0
110449	Unknown +details Unknown	Unknown	Unknown	0/0
110448	Unknown +details Unknown	Unknown	Unknown	0/0
110447	Unknown +details Unknown	Unknown	Unknown	0/0
110446	Unknown +details Unknown	Unknown	Unknown	0/0
110445	Unknown +details Unknown	Unknown	Unknown	0/0
110444	Unknown +details Unknown	Unknown	Unknown	0/0
110443	Unknown +details Unknown	Unknown	Unknown	0/0
110442	Unknown +details Unknown	Unknown	Unknown	0/0
110441	Unknown +details Unknown	Unknown	Unknown	0/0
110440	Unknown +details Unknown	Unknown	Unknown	0/0
110439	Unknown +details Unknown	Unknown	Unknown	0/0
110438	Unknown +details Unknown	Unknown	Unknown	0/0
110437	Unknown +details Unknown	Unknown	Unknown	0/0
110436	Unknown +details Unknown	Unknown	Unknown	0/0
110435	Unknown +details Unknown	Unknown	Unknown	0/0
110434	Unknown +details Unknown	Unknown	Unknown	0/0
110433	Unknown +details Unknown	Unknown	Unknown	0/0
110432	Unknown +details Unknown	Unknown	Unknown	0/0
110431	Unknown +details Unknown	Unknown	Unknown	0/0
110430	Unknown +details Unknown	Unknown	Unknown	0/0
110429	Unknown +details Unknown	Unknown	Unknown	0/0
110428	Unknown +details Unknown	Unknown	Unknown	0/0
110427	Unknown +details Unknown	Unknown	Unknown	0/0

Page: