No DAG visualization information to display for job 56518
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1573072 | tenants-pool-679 | stream-10000002290-1
id = 9de6f34f-766f-4f9e-a20a-4d04550271a4
runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02
batch = 49 start at FileStorageAdapterImpl.java:598 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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/07/22 02:21:50 | 30 ms |
30/30
| 18.3 KiB | |||
| 1573071 | tenants-pool-679 | stream-10000002290-1
id = 9de6f34f-766f-4f9e-a20a-4d04550271a4
runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02
batch = 49 start at FileStorageAdapterImpl.java:598 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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/07/22 02:21:50 | 0.2 s |
30/30
| 10.5 KiB | 18.3 KiB | ||
| 1573070 | tenants-pool-679 | stream-10000002290-1
id = 9de6f34f-766f-4f9e-a20a-4d04550271a4
runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02
batch = 49 start at FileStorageAdapterImpl.java:598
RDD: MapPartitionsRDD
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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/07/22 02:21:50 | 0.4 s |
60/60
| 15.3 KiB | 8.2 KiB | ||
| 1573069 | tenants-pool-679 | stream-10000002290-1
id = 9de6f34f-766f-4f9e-a20a-4d04550271a4
runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02
batch = 49 start at FileStorageAdapterImpl.java:598 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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/07/22 02:21:50 | 57 ms |
30/30
| 2.3 KiB | 2.3 KiB | ||
| 1573068 | tenants-pool-679 | stream-10000002290-1
id = 9de6f34f-766f-4f9e-a20a-4d04550271a4
runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02
batch = 49 start at FileStorageAdapterImpl.java:598
RDD: MapPartitionsRDD
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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/07/22 02:21:50 | 0.3 s |
60/60
| 15.3 KiB | 2.3 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1573067 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573066 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573065 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573064 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573063 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573062 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573061 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573060 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573059 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573058 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573057 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573056 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573055 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573054 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573053 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573052 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573051 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573050 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573049 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573048 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573047 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573046 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573045 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573044 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573043 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573042 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573041 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573040 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573039 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573038 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573037 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573036 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573035 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573034 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573033 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573032 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573031 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573030 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573029 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573028 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573027 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573026 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573025 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573024 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573023 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573022 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573021 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573020 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573019 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573018 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573017 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573016 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573015 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573014 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573013 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573012 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573011 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573010 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573009 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573008 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573007 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573006 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573005 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573004 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573003 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573002 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573001 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573000 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572999 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572998 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572997 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572996 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572995 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572994 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572993 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572992 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572991 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572990 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572989 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572988 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572987 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572986 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572985 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572984 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572983 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572982 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572981 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572980 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572979 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572978 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572977 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572976 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572975 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572974 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572973 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572972 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572971 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572970 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572969 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1572968 | Unknown Unknown | Unknown | Unknown |
0/0
|