No DAG visualization information to display for job 47282
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1341656 | tenants-pool-169 | stream-10000001445-1
id = 26c9c63a-530b-4359-9e14-1592a674aa0e
runId = 881110fc-a22e-43dd-9ef6-858dd65243b7
batch = 101 start at FileStorageAdapterImpl.java:598
RDD: MapPartitionsRDD*(3) Project [shardId#5591588, worklistShardItemId#5591666L, version#5591675, product#5591736, plant#5591731, availabilityDateTime#5591738 AS periodStart#5591775, nextAvailabilityDateTime#5591739 AS periodEnd#5591776, qty#5591671]
+- *(3) BroadcastHashJoin [worklistShardItemId#5591666L], [worklistShardItemId#5591750L], LeftOuter, BuildRight, (shardId#5591588 = 0_1_10000001445), false
:- *(3) Project [shardId#5591588, worklistShardItemId#5591666L, qty#5591671, element_at([12], ((cast(array_position([0_1_10000001445], shardId#5591588) as int) - 1) + 1), None, false) AS version#5591675]
: +- *(3) Generate explode(requestedQuantities#5591669), [shardId#5591588, worklistShardItemId#5591666L], false, [qty#5591671]
: +- *(3) Project [shardId#5591588, item#5591665.worklistShardItemId AS worklistShardItemId#5591666L, item#5591665.requestedQuantities AS requestedQuantities#5591669]
: +- *(3) Filter ((size(item#5591665.requestedQuantities, true) > 0) AND isnotnull(item#5591665.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:58:50 | 0.2 s |
30/30
| 996.0 B | 3.9 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1341655 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341654 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341653 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341652 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341651 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341650 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341649 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341648 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341647 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341646 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341645 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341644 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341643 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341642 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341641 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341640 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341639 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341638 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341637 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341636 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341635 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341634 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341633 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341632 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341631 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341630 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341629 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341628 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341627 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341626 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341625 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341624 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341623 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341622 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341621 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341620 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341619 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341618 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341617 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341616 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341615 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341614 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341613 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341612 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341611 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341610 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341609 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341608 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341607 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341606 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341605 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341604 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341603 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341602 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341601 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341600 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341599 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341598 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341597 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341596 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341595 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341594 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341593 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341592 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341591 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341590 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341589 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341588 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341587 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341586 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341585 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341584 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341583 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341582 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341581 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341580 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341579 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341578 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341577 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341576 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341575 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341574 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341573 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341572 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341571 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341570 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341569 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341568 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341567 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341566 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341565 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341564 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341563 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341562 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341561 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341560 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341559 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341558 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341557 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1341556 | Unknown Unknown | Unknown | Unknown |
0/0
|