No DAG visualization information to display for job 127218
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 3725212 | tenants-pool-169 | stream-10000001452-1
id = d8095b92-94ab-46e0-9c45-70c2545e39e1
runId = f82340b3-4413-4826-9fdb-37fdaa6940fe
batch = 68 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 20:36:40 | 29 ms |
30/30
| 1548.0 B | |||
| 3725211 | tenants-pool-169 | stream-10000001452-1
id = d8095b92-94ab-46e0-9c45-70c2545e39e1
runId = f82340b3-4413-4826-9fdb-37fdaa6940fe
batch = 68 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 20:36:40 | 0.3 s |
30/30
| 796.0 B | 1548.0 B | ||
| 3725210 | tenants-pool-169 | stream-10000001452-1
id = d8095b92-94ab-46e0-9c45-70c2545e39e1
runId = f82340b3-4413-4826-9fdb-37fdaa6940fe
batch = 68 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 20:36:40 | 0.2 s |
30/30
| 216.0 B | 216.0 B | ||
| 3725209 | tenants-pool-169 | stream-10000001452-1
id = d8095b92-94ab-46e0-9c45-70c2545e39e1
runId = f82340b3-4413-4826-9fdb-37fdaa6940fe
batch = 68 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 20:36:39 | 0.3 s |
60/60
| 3.0 KiB | 580.0 B | ||
| 3725208 | tenants-pool-169 | stream-10000001452-1
id = d8095b92-94ab-46e0-9c45-70c2545e39e1
runId = f82340b3-4413-4826-9fdb-37fdaa6940fe
batch = 68 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 20:36:39 | 0.3 s |
60/60
| 3.0 KiB | 216.0 B |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 3725207 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725206 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725205 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725204 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725203 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725202 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725201 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725200 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725199 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725198 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725197 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725196 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725195 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725194 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725193 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725192 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725191 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725190 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725189 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725188 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725187 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725186 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725185 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725184 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725183 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725182 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725181 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725180 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725179 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725178 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725177 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725176 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725175 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725174 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725173 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725172 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725171 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725170 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725169 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725168 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725167 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725166 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725165 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725164 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725163 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725162 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725161 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725160 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725159 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725158 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725157 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725156 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725155 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725154 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725153 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725152 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725151 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725150 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725149 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725148 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725147 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725146 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725145 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725144 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725143 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725142 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725141 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725140 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725139 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725138 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725137 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725136 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725135 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725134 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725133 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725132 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725131 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725130 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725129 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725128 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725127 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725126 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725125 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725124 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725123 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725122 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725121 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725120 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725119 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725118 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725117 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725116 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725115 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725114 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725113 | Unknown Unknown | Unknown | Unknown |
0/0
|