No DAG visualization information to display for job 40874
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1262289 | tenants-pool-169 | stream-10000000244-1
id = f4ddbf18-85c1-4896-8727-ce8f46084bea
runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807
batch = 38 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:07:20 | 0.2 s |
30/30
| 34.6 KiB | |||
| 1262288 | tenants-pool-169 | stream-10000000244-1
id = f4ddbf18-85c1-4896-8727-ce8f46084bea
runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807
batch = 38 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:07:20 | 0.6 s |
30/30
| 44.2 KiB | 34.6 KiB | ||
| 1262287 | tenants-pool-169 | stream-10000000244-1
id = f4ddbf18-85c1-4896-8727-ce8f46084bea
runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807
batch = 38 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:07:19 | 1 s |
30/30
| 150.9 KiB | 19.4 KiB | ||
| 1262286 | tenants-pool-169 | stream-10000000244-1
id = f4ddbf18-85c1-4896-8727-ce8f46084bea
runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807
batch = 38 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:07:18 | 0.4 s |
25/25
| 25.5 KiB | |||
| 1262285 | tenants-pool-169 | stream-10000000244-1
id = f4ddbf18-85c1-4896-8727-ce8f46084bea
runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807
batch = 38 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:07:18 | 0.2 s |
30/30
| 66.3 KiB | 150.7 KiB | ||
| 1262284 | tenants-pool-169 | stream-10000000244-1
id = f4ddbf18-85c1-4896-8727-ce8f46084bea
runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807
batch = 38 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:07:18 | 98 ms |
30/30
| 1182.0 B | 2.2 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1262283 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262282 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262281 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262280 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262279 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262278 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262277 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262276 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262275 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262274 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262273 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262272 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262271 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262270 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262269 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262268 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262267 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262266 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262265 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262264 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262263 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262262 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262261 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262260 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262259 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262258 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262257 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262256 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262255 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262254 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262253 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262252 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262251 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262250 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262249 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262248 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262247 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262246 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262245 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262244 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262243 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262242 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262241 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262240 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262239 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262238 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262237 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262236 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262235 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262234 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262233 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262232 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262231 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262230 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262229 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262228 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262227 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262226 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262225 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262224 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262223 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262222 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262221 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262220 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262219 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262218 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262217 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262216 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262215 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262214 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262213 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262212 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262211 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262210 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262209 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262208 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262207 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262206 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262205 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262204 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262203 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262202 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262201 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262200 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262199 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262198 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262197 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262196 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262195 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262194 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262193 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262192 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262191 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262190 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262189 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262188 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262187 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262186 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262185 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1262184 | Unknown Unknown | Unknown | Unknown |
0/0
|