No DAG visualization information to display for job 47166
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1335531 | tenants-pool-169 | stream-10000001445-1
id = 26c9c63a-530b-4359-9e14-1592a674aa0e
runId = 881110fc-a22e-43dd-9ef6-858dd65243b7
batch = 97 start at FileStorageAdapterImpl.java:598
RDD: MapPartitionsRDD*(3) Project [shardId#5581730, worklistShardItemId#5581808L, version#5581817, product#5581878, plant#5581873, availabilityDateTime#5581880 AS periodStart#5581917, nextAvailabilityDateTime#5581881 AS periodEnd#5581918, qty#5581813]
+- *(3) BroadcastHashJoin [worklistShardItemId#5581808L], [worklistShardItemId#5581892L], LeftOuter, BuildRight, (shardId#5581730 = 0_1_10000001445), false
:- *(3) Project [shardId#5581730, worklistShardItemId#5581808L, qty#5581813, element_at([8], ((cast(array_position([0_1_10000001445], shardId#5581730) as int) - 1) + 1), None, false) AS version#5581817]
: +- *(3) Generate explode(requestedQuantities#5581811), [shardId#5581730, worklistShardItemId#5581808L], false, [qty#5581813]
: +- *(3) Project [shardId#5581730, item#5581807.worklistShardItemId AS worklistShardItemId#5581808L, item#5581807.requestedQuantities AS requestedQuantities#5581811]
: +- *(3) Filter ((size(item#5581807.requestedQuantities, true) > 0) AND isnotnull(item#5581807.requestedQuantiti...
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:03 | 0.2 s |
30/30
| 1149.0 B | 4.0 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1335530 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335529 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335528 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335527 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335526 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335525 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335524 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335523 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335522 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335521 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335520 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335519 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335518 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335517 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335516 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335515 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335514 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335513 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335512 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335511 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335510 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335509 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335508 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335507 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335506 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335505 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335504 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335503 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335502 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335501 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335500 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335499 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335498 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335497 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335496 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335495 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335494 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335493 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335492 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335491 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335490 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335489 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335488 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335487 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335486 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335485 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335484 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335483 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335482 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335481 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335480 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335479 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335478 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335477 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335476 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335475 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335474 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335473 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335472 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335471 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335470 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335469 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335468 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335467 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335466 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335465 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335464 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335463 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335462 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335461 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335460 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335459 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335458 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335457 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335456 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335455 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335454 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335453 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335452 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335451 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335450 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335449 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335448 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335447 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335446 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335445 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335444 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335443 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335442 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1335441 | Unknown Unknown | Unknown | Unknown |
0/0
|