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

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

Enable zooming

No DAG visualization information to display for job 6046

Completed Stages (7)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Shuffle Read	Shuffle Write
109390	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 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 20:12:03	0.2 s	37/37		1200.0 B
109389	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 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 20:12:02	0.9 s	74/74	777.0 B	3.0 KiB	1200.0 B
109388	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 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 20:12:01	0.1 s	37/37	3.2 KiB		3.0 KiB
109387	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 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 20:12:02	0.5 s	74/74	58.3 KiB	72.0 KiB
109386	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 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 20:12:02	86 ms	37/37
109385	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 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 20:12:01	0.3 s	37/37	58.3 KiB		146.4 KiB
109384	tenants-pool-780	stream-10000000349-1 id = 93409909-6965-46ba-a5f4-cc04bff91a3e runId = 1785dd42-a3bd-40d2-8e91-765a57162f64 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 20:12:01	0.2 s	37/37	58.3 KiB

Page:

Skipped Stages (109)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total
109383	Unknown +details Unknown	Unknown	Unknown	0/0
109382	Unknown +details Unknown	Unknown	Unknown	0/0
109381	Unknown +details Unknown	Unknown	Unknown	0/0
109380	Unknown +details Unknown	Unknown	Unknown	0/0
109379	Unknown +details Unknown	Unknown	Unknown	0/0
109378	Unknown +details Unknown	Unknown	Unknown	0/0
109377	Unknown +details Unknown	Unknown	Unknown	0/0
109376	Unknown +details Unknown	Unknown	Unknown	0/0
109375	Unknown +details Unknown	Unknown	Unknown	0/0
109374	Unknown +details Unknown	Unknown	Unknown	0/0
109373	Unknown +details Unknown	Unknown	Unknown	0/0
109372	Unknown +details Unknown	Unknown	Unknown	0/0
109371	Unknown +details Unknown	Unknown	Unknown	0/0
109370	Unknown +details Unknown	Unknown	Unknown	0/0
109369	Unknown +details Unknown	Unknown	Unknown	0/0
109368	Unknown +details Unknown	Unknown	Unknown	0/0
109367	Unknown +details Unknown	Unknown	Unknown	0/0
109366	Unknown +details Unknown	Unknown	Unknown	0/0
109365	Unknown +details Unknown	Unknown	Unknown	0/0
109364	Unknown +details Unknown	Unknown	Unknown	0/0
109363	Unknown +details Unknown	Unknown	Unknown	0/0
109362	Unknown +details Unknown	Unknown	Unknown	0/0
109361	Unknown +details Unknown	Unknown	Unknown	0/0
109360	Unknown +details Unknown	Unknown	Unknown	0/0
109359	Unknown +details Unknown	Unknown	Unknown	0/0
109358	Unknown +details Unknown	Unknown	Unknown	0/0
109357	Unknown +details Unknown	Unknown	Unknown	0/0
109356	Unknown +details Unknown	Unknown	Unknown	0/0
109355	Unknown +details Unknown	Unknown	Unknown	0/0
109354	Unknown +details Unknown	Unknown	Unknown	0/0
109353	Unknown +details Unknown	Unknown	Unknown	0/0
109352	Unknown +details Unknown	Unknown	Unknown	0/0
109351	Unknown +details Unknown	Unknown	Unknown	0/0
109350	Unknown +details Unknown	Unknown	Unknown	0/0
109349	Unknown +details Unknown	Unknown	Unknown	0/0
109348	Unknown +details Unknown	Unknown	Unknown	0/0
109347	Unknown +details Unknown	Unknown	Unknown	0/0
109346	Unknown +details Unknown	Unknown	Unknown	0/0
109345	Unknown +details Unknown	Unknown	Unknown	0/0
109344	Unknown +details Unknown	Unknown	Unknown	0/0
109343	Unknown +details Unknown	Unknown	Unknown	0/0
109342	Unknown +details Unknown	Unknown	Unknown	0/0
109341	Unknown +details Unknown	Unknown	Unknown	0/0
109340	Unknown +details Unknown	Unknown	Unknown	0/0
109339	Unknown +details Unknown	Unknown	Unknown	0/0
109338	Unknown +details Unknown	Unknown	Unknown	0/0
109337	Unknown +details Unknown	Unknown	Unknown	0/0
109336	Unknown +details Unknown	Unknown	Unknown	0/0
109335	Unknown +details Unknown	Unknown	Unknown	0/0
109334	Unknown +details Unknown	Unknown	Unknown	0/0
109333	Unknown +details Unknown	Unknown	Unknown	0/0
109332	Unknown +details Unknown	Unknown	Unknown	0/0
109331	Unknown +details Unknown	Unknown	Unknown	0/0
109330	Unknown +details Unknown	Unknown	Unknown	0/0
109329	Unknown +details Unknown	Unknown	Unknown	0/0
109328	Unknown +details Unknown	Unknown	Unknown	0/0
109327	Unknown +details Unknown	Unknown	Unknown	0/0
109326	Unknown +details Unknown	Unknown	Unknown	0/0
109325	Unknown +details Unknown	Unknown	Unknown	0/0
109324	Unknown +details Unknown	Unknown	Unknown	0/0
109323	Unknown +details Unknown	Unknown	Unknown	0/0
109322	Unknown +details Unknown	Unknown	Unknown	0/0
109321	Unknown +details Unknown	Unknown	Unknown	0/0
109320	Unknown +details Unknown	Unknown	Unknown	0/0
109319	Unknown +details Unknown	Unknown	Unknown	0/0
109318	Unknown +details Unknown	Unknown	Unknown	0/0
109317	Unknown +details Unknown	Unknown	Unknown	0/0
109316	Unknown +details Unknown	Unknown	Unknown	0/0
109315	Unknown +details Unknown	Unknown	Unknown	0/0
109314	Unknown +details Unknown	Unknown	Unknown	0/0
109313	Unknown +details Unknown	Unknown	Unknown	0/0
109312	Unknown +details Unknown	Unknown	Unknown	0/0
109311	Unknown +details Unknown	Unknown	Unknown	0/0
109310	Unknown +details Unknown	Unknown	Unknown	0/0
109309	Unknown +details Unknown	Unknown	Unknown	0/0
109308	Unknown +details Unknown	Unknown	Unknown	0/0
109307	Unknown +details Unknown	Unknown	Unknown	0/0
109306	Unknown +details Unknown	Unknown	Unknown	0/0
109305	Unknown +details Unknown	Unknown	Unknown	0/0
109304	Unknown +details Unknown	Unknown	Unknown	0/0
109303	Unknown +details Unknown	Unknown	Unknown	0/0
109302	Unknown +details Unknown	Unknown	Unknown	0/0
109301	Unknown +details Unknown	Unknown	Unknown	0/0
109300	Unknown +details Unknown	Unknown	Unknown	0/0
109299	Unknown +details Unknown	Unknown	Unknown	0/0
109298	Unknown +details Unknown	Unknown	Unknown	0/0
109297	Unknown +details Unknown	Unknown	Unknown	0/0
109296	Unknown +details Unknown	Unknown	Unknown	0/0
109295	Unknown +details Unknown	Unknown	Unknown	0/0
109294	Unknown +details Unknown	Unknown	Unknown	0/0
109293	Unknown +details Unknown	Unknown	Unknown	0/0
109292	Unknown +details Unknown	Unknown	Unknown	0/0
109291	Unknown +details Unknown	Unknown	Unknown	0/0
109290	Unknown +details Unknown	Unknown	Unknown	0/0
109289	Unknown +details Unknown	Unknown	Unknown	0/0
109288	Unknown +details Unknown	Unknown	Unknown	0/0
109287	Unknown +details Unknown	Unknown	Unknown	0/0
109286	Unknown +details Unknown	Unknown	Unknown	0/0
109285	Unknown +details Unknown	Unknown	Unknown	0/0
109284	Unknown +details Unknown	Unknown	Unknown	0/0

Page: