No DAG visualization information to display for job 52711
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1033335 | 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:42 | 83 ms |
30/30
| 1834.9 KiB | |||
| 1033334 | 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:42 | 0.4 s |
30/30
| 2.6 MiB | 1834.9 KiB | ||
| 1033333 | 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:41 | 0.4 s |
67/67
| 2006.5 KiB | 2.4 MiB | ||
| 1033332 | 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:41 | 0.2 s |
30/30
| 201.5 KiB | 150.9 KiB | ||
| 1033331 | 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:41 | 0.6 s |
67/67
| 2006.5 KiB | 201.5 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1033330 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033329 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033328 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033327 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033326 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033325 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033324 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033323 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033322 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033321 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033320 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033319 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033318 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033317 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033316 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033315 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033314 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033313 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033312 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033311 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033310 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033309 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033308 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033307 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033306 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033305 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033304 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033303 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033302 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033301 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033300 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033299 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033298 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033297 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033296 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033295 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033294 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033293 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033292 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033291 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033290 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033289 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033288 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033287 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033286 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033285 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033284 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033283 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033282 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033281 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033280 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033279 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033278 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033277 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033276 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033275 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033274 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033273 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033272 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033271 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033270 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033269 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033268 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033267 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033266 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033265 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033264 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033263 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033262 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033261 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033260 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033259 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033258 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033257 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033256 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033255 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033254 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033253 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033252 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033251 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033250 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033249 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033248 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033247 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033246 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033245 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033244 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033243 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033242 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033241 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033240 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033239 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033238 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033237 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033236 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033235 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033234 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033233 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033232 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033231 | Unknown Unknown | Unknown | Unknown |
0/0
|