No DAG visualization information to display for job 47223
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1338371 | tenants-pool-169 | stream-10000001445-1
id = 26c9c63a-530b-4359-9e14-1592a674aa0e
runId = 881110fc-a22e-43dd-9ef6-858dd65243b7
batch = 99 start at FileStorageAdapterImpl.java:598
RDD: MapPartitionsRDD*(3) Project [shardId#5586482, worklistShardItemId#5586560L, version#5586569, product#5586630, plant#5586625, availabilityDateTime#5586632 AS periodStart#5586669, nextAvailabilityDateTime#5586633 AS periodEnd#5586670, qty#5586565]
+- *(3) BroadcastHashJoin [worklistShardItemId#5586560L], [worklistShardItemId#5586644L], LeftOuter, BuildRight, (shardId#5586482 = 0_1_10000001445), false
:- *(3) Project [shardId#5586482, worklistShardItemId#5586560L, qty#5586565, element_at([10], ((cast(array_position([0_1_10000001445], shardId#5586482) as int) - 1) + 1), None, false) AS version#5586569]
: +- *(3) Generate explode(requestedQuantities#5586563), [shardId#5586482, worklistShardItemId#5586560L], false, [qty#5586565]
: +- *(3) Project [shardId#5586482, item#5586559.worklistShardItemId AS worklistShardItemId#5586560L, item#5586559.requestedQuantities AS requestedQuantities#5586563]
: +- *(3) Filter ((size(item#5586559.requestedQuantities, true) > 0) AND isnotnull(item#5586559.requestedQuantit...
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/21 20:57:53 | 0.2 s |
30/30
| 994.0 B | 3.9 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1338370 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338369 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338368 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338367 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338366 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338365 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338364 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338363 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338362 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338361 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338360 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338359 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338358 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338357 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338356 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338355 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338354 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338353 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338352 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338351 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338350 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338349 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338348 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338347 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338346 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338345 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338344 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338343 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338342 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338341 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338340 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338339 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338338 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338337 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338336 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338335 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338334 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338333 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338332 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338331 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338330 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338329 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338328 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338327 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338326 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338325 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338324 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338323 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338322 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338321 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338320 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338319 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338318 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338317 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338316 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338315 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338314 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338313 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338312 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338311 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338310 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338309 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338308 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338307 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338306 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338305 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338304 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338303 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338302 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338301 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338300 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338299 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338298 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338297 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338296 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338295 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338294 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338293 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338292 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338291 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338290 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338289 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338288 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338287 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338286 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338285 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338284 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338283 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338282 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338281 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338280 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338279 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338278 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338277 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338276 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338275 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338274 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338273 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338272 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1338271 | Unknown Unknown | Unknown | Unknown |
0/0
|