No DAG visualization information to display for job 52710
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1033179 | 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:40 | 0.7 s |
30/30
| 5.8 MiB | |||
| 1033178 | 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:39 | 0.6 s |
30/30
| 5.1 MiB | 5.8 MiB | ||
| 1033177 | 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:37 | 2 s |
30/30
| 20.3 MiB | 1269.6 KiB | ||
| 1033176 | 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:36 | 0.7 s |
37/37
| 3.8 MiB | |||
| 1033175 | 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:36 | 2 s |
30/30
| 94.9 MiB | 19.5 MiB | ||
| 1033174 | 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:36 | 75 ms |
30/30
| 137.7 KiB | 805.5 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1033173 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033172 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033171 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033170 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033169 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033168 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033167 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033166 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033165 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033164 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033163 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033162 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033161 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033160 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033159 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033158 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033157 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033156 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033155 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033154 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033153 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033152 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033151 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033150 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033149 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033148 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033147 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033146 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033145 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033144 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033143 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033142 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033141 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033140 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033139 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033138 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033137 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033136 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033135 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033134 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033133 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033132 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033131 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033130 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033129 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033128 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033127 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033126 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033125 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033124 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033123 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033122 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033121 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033120 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033119 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033118 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033117 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033116 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033115 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033114 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033113 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033112 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033111 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033110 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033109 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033108 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033107 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033106 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033105 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033104 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033103 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033102 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033101 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033100 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033099 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033098 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033097 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033096 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033095 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033094 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033093 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033092 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033091 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033090 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033089 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033088 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033087 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033086 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033085 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033084 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033083 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033082 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033081 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033080 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033079 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033078 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033077 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033076 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033075 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033074 | Unknown Unknown | Unknown | Unknown |
0/0
|