No DAG visualization information to display for job 40994
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1269459 | tenants-pool-169 | stream-10000000244-1
id = f4ddbf18-85c1-4896-8727-ce8f46084bea
runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807
batch = 40 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:09:29 | 34 ms |
30/30
| 1426.0 B | |||
| 1269458 | tenants-pool-169 | stream-10000000244-1
id = f4ddbf18-85c1-4896-8727-ce8f46084bea
runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807
batch = 40 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:09:29 | 0.7 s |
30/30
| 584.0 B | 1426.0 B | ||
| 1269457 | tenants-pool-169 | stream-10000000244-1
id = f4ddbf18-85c1-4896-8727-ce8f46084bea
runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807
batch = 40 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:09:29 | 0.2 s |
30/30
| 216.0 B | 216.0 B | ||
| 1269456 | tenants-pool-169 | stream-10000000244-1
id = f4ddbf18-85c1-4896-8727-ce8f46084bea
runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807
batch = 40 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:09:28 | 0.9 s |
67/67
| 2.9 KiB | 368.0 B | ||
| 1269455 | tenants-pool-169 | stream-10000000244-1
id = f4ddbf18-85c1-4896-8727-ce8f46084bea
runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807
batch = 40 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:09:28 | 0.8 s |
67/67
| 2.9 KiB | 216.0 B |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1269454 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269453 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269452 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269451 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269450 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269449 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269448 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269447 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269446 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269445 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269444 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269443 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269442 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269441 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269440 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269439 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269438 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269437 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269436 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269435 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269434 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269433 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269432 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269431 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269430 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269429 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269428 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269427 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269426 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269425 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269424 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269423 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269422 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269421 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269420 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269419 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269418 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269417 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269416 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269415 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269414 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269413 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269412 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269411 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269410 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269409 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269408 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269407 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269406 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269405 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269404 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269403 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269402 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269401 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269400 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269399 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269398 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269397 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269396 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269395 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269394 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269393 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269392 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269391 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269390 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269389 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269388 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269387 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269386 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269385 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269384 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269383 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269382 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269381 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269380 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269379 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269378 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269377 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269376 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269375 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269374 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269373 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269372 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269371 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269370 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269369 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269368 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269367 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269366 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269365 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269364 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269363 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269362 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269361 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269360 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269359 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269358 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269357 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269356 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1269355 | Unknown Unknown | Unknown | Unknown |
0/0
|