No DAG visualization information to display for job 52718
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1034272 | 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:11 | 18 ms |
30/30
| 2.7 KiB | |||
| 1034271 | 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:11 | 26 ms |
30/30
| 673.1 KiB | 2.7 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1034270 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034269 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034268 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034267 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034266 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034265 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034264 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034263 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034262 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034261 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034260 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034259 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034258 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034257 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034256 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034255 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034254 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034253 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034252 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034251 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034250 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034249 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034248 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034247 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034246 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034245 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034244 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034243 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034242 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034241 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034240 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034239 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034238 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034237 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034236 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034235 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034234 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034233 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034232 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034231 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034230 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034229 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034228 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034227 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034226 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034225 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034224 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034223 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034222 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034221 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034220 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034219 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034218 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034217 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034216 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034215 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034214 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034213 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034212 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034211 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034210 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034209 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034208 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034207 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034206 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034205 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034204 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034203 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034202 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034201 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034200 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034199 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034198 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034197 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034196 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034195 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034194 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034193 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034192 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034191 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034190 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034189 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034188 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034187 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034186 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034185 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034184 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034183 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034182 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034181 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034180 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034179 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034178 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034177 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034176 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034175 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034174 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034173 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034172 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1034171 | Unknown Unknown | Unknown | Unknown |
0/0
|