No DAG visualization information to display for job 52728
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1035251 | tenants-pool-506 | stream-10000000540-2
id = 386dabc1-f677-44f7-82d8-69fe99072c2c
runId = 1ebd557e-9283-4610-a07b-41d13bb785c5
batch = 31 start at FileStorageAdapterImpl.java:596 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/09/01 14:16:27 | 0.2 s |
30/30
| ||||
| 1035250 | tenants-pool-506 | stream-10000000540-2
id = 386dabc1-f677-44f7-82d8-69fe99072c2c
runId = 1ebd557e-9283-4610-a07b-41d13bb785c5
batch = 31 start at FileStorageAdapterImpl.java:596 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/09/01 14:16:26 | 0.2 s |
30/30
| 337.4 KiB | |||
| 1035249 | tenants-pool-506 | stream-10000000540-2
id = 386dabc1-f677-44f7-82d8-69fe99072c2c
runId = 1ebd557e-9283-4610-a07b-41d13bb785c5
batch = 31 start at FileStorageAdapterImpl.java:596
RDD: *(1) Filter (isnotnull(shardId#10214802) AND (shardId#10214802 = 0_3_10000000540))
+- *(1) Scan ExistingRDD[shardId#10214802,orderProposalId#10214803L,items#10214804,optimizationGroups#10214805,isOptimal#10214806,lastModified#10214807,optimizationInsights#10214808]
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/09/01 14:16:26 | 0.2 s |
30/30
| 673.1 KiB | |||
| 1035248 | tenants-pool-506 | stream-10000000540-2
id = 386dabc1-f677-44f7-82d8-69fe99072c2c
runId = 1ebd557e-9283-4610-a07b-41d13bb785c5
batch = 31 start at FileStorageAdapterImpl.java:596 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/09/01 14:16:26 | 0.2 s |
30/30
| 1745.1 KiB | 675.6 KiB | ||
| 1035247 | tenants-pool-506 | stream-10000000540-2
id = 386dabc1-f677-44f7-82d8-69fe99072c2c
runId = 1ebd557e-9283-4610-a07b-41d13bb785c5
batch = 31 start at FileStorageAdapterImpl.java:596 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/09/01 14:16:26 | 0.5 s |
37/37
| 1745.1 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1035246 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035245 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035244 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035243 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035242 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035241 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035240 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035239 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035238 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035237 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035236 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035235 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035234 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035233 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035232 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035231 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035230 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035229 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035228 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035227 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035226 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035225 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035224 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035223 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035222 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035221 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035220 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035219 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035218 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035217 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035216 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035215 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035214 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035213 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035212 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035211 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035210 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035209 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035208 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035207 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035206 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035205 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035204 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035203 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035202 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035201 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035200 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035199 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035198 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035197 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035196 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035195 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035194 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035193 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035192 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035191 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035190 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035189 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035188 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035187 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035186 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035185 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035184 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035183 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035182 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035181 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035180 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035179 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035178 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035177 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035176 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035175 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035174 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035173 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035172 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035171 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035170 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035169 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035168 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035167 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035166 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035165 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035164 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035163 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035162 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035161 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035160 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035159 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035158 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035157 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035156 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035155 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035154 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035153 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035152 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035151 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035150 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035149 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035148 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1035147 | Unknown Unknown | Unknown | Unknown |
0/0
|