No DAG visualization information to display for job 40821
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1259338 | tenants-pool-169 | stream-10000000244-1
id = f4ddbf18-85c1-4896-8727-ce8f46084bea
runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807
batch = 36 start at FileStorageAdapterImpl.java:567 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/05/22 09:06:00 | 35 ms |
30/30
| 5.1 KiB | |||
| 1259337 | tenants-pool-169 | stream-10000000244-1
id = f4ddbf18-85c1-4896-8727-ce8f46084bea
runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807
batch = 36 start at FileStorageAdapterImpl.java:567 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/05/22 09:05:59 | 0.7 s |
30/30
| 2.3 KiB | 5.1 KiB | ||
| 1259336 | tenants-pool-169 | stream-10000000244-1
id = f4ddbf18-85c1-4896-8727-ce8f46084bea
runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807
batch = 36 start at FileStorageAdapterImpl.java:567 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/05/22 09:05:59 | 0.2 s |
30/30
| 756.0 B | 756.0 B | ||
| 1259335 | tenants-pool-169 | stream-10000000244-1
id = f4ddbf18-85c1-4896-8727-ce8f46084bea
runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807
batch = 36 start at FileStorageAdapterImpl.java:567 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/05/22 09:05:58 | 0.8 s |
67/67
| 7.5 KiB | 1567.0 B | ||
| 1259334 | tenants-pool-169 | stream-10000000244-1
id = f4ddbf18-85c1-4896-8727-ce8f46084bea
runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807
batch = 36 start at FileStorageAdapterImpl.java:567 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/05/22 09:05:58 | 0.8 s |
67/67
| 7.5 KiB | 756.0 B |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1259333 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259332 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259331 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259330 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259329 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259328 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259327 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259326 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259325 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259324 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259323 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259322 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259321 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259320 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259319 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259318 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259317 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259316 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259315 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259314 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259313 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259312 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259311 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259310 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259309 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259308 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259307 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259306 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259305 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259304 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259303 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259302 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259301 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259300 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259299 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259298 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259297 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259296 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259295 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259294 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259293 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259292 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259291 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259290 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259289 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259288 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259287 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259286 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259285 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259284 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259283 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259282 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259281 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259280 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259279 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259278 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259277 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259276 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259275 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259274 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259273 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259272 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259271 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259270 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259269 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259268 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259267 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259266 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259265 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259264 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259263 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259262 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259261 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259260 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259259 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259258 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259257 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259256 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259255 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259254 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259253 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259252 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259251 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259250 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259249 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259248 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259247 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259246 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259245 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259244 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259243 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259242 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259241 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259240 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259239 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259238 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259237 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259236 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259235 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1259234 | Unknown Unknown | Unknown | Unknown |
0/0
|