No DAG visualization information to display for job 52696
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1032855 | tenants-pool-506 | stream-10000000540-2
id = 386dabc1-f677-44f7-82d8-69fe99072c2c
runId = 1ebd557e-9283-4610-a07b-41d13bb785c5
batch = 31 start at FileStorageAdapterImpl.java:596 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/09/01 14:15:31 | 0.2 s |
30/30
| 2.7 KiB | |||
| 1032854 | tenants-pool-506 | stream-10000000540-2
id = 386dabc1-f677-44f7-82d8-69fe99072c2c
runId = 1ebd557e-9283-4610-a07b-41d13bb785c5
batch = 31 start at FileStorageAdapterImpl.java:596 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/09/01 14:15:31 | 0.4 s |
30/30
| 18.6 MiB | 2.7 KiB | ||
| 1032853 | tenants-pool-506 | stream-10000000540-2
id = 386dabc1-f677-44f7-82d8-69fe99072c2c
runId = 1ebd557e-9283-4610-a07b-41d13bb785c5
batch = 31 start at FileStorageAdapterImpl.java:596 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/09/01 14:15:29 | 0.2 s |
30/30
| 137.7 KiB | 805.5 KiB | ||
| 1032852 | tenants-pool-506 | stream-10000000540-2
id = 386dabc1-f677-44f7-82d8-69fe99072c2c
runId = 1ebd557e-9283-4610-a07b-41d13bb785c5
batch = 31 start at FileStorageAdapterImpl.java:596
RDD: MapPartitionsRDD
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/09/01 14:15:29 | 1 s |
30/30
| 94.9 MiB | 17.8 MiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1032851 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032850 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032849 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032848 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032847 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032846 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032827 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032826 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032825 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032824 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032823 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032822 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032821 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032820 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032819 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032818 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032817 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032816 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032815 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032814 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032813 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032812 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032811 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032810 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032809 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032808 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032807 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032806 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032805 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032804 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032803 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032802 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032801 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032800 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032799 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032798 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032797 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032796 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032795 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032794 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032793 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032792 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032791 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032790 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032789 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032788 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032787 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032786 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032785 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032784 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032783 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032782 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032781 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032780 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032779 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032778 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032777 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032776 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032775 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032774 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032773 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032772 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032771 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032770 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032769 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032768 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032767 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032766 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032765 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032764 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032763 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032762 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032761 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032760 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032759 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032758 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032757 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032756 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032755 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032754 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032753 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032752 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032751 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032750 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032749 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032748 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032747 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032746 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032745 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032744 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032743 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032742 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032741 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032740 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032739 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032738 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032737 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032736 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032735 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032734 | Unknown Unknown | Unknown | Unknown |
0/0
|