No DAG visualization information to display for job 127226
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 3725797 | tenants-pool-169 | stream-10000001452-1
id = d8095b92-94ab-46e0-9c45-70c2545e39e1
runId = f82340b3-4413-4826-9fdb-37fdaa6940fe
batch = 68 start at FileStorageAdapterImpl.java:598
RDD: MapPartitionsRDD*(3) Project [shardId#15068308, worklistShardItemId#15068386L, version#15068395, product#15068456, plant#15068451, availabilityDateTime#15068458 AS periodStart#15068495, nextAvailabilityDateTime#15068459 AS periodEnd#15068496, qty#15068391]
+- *(3) BroadcastHashJoin [worklistShardItemId#15068386L], [worklistShardItemId#15068470L], LeftOuter, BuildRight, (shardId#15068308 = 0_1_10000001452), false
:- *(3) Project [shardId#15068308, worklistShardItemId#15068386L, qty#15068391, element_at([12], ((cast(array_position([0_1_10000001452], shardId#15068308) as int) - 1) + 1), None, false) AS version#15068395]
: +- *(3) Generate explode(requestedQuantities#15068389), [shardId#15068308, worklistShardItemId#15068386L], false, [qty#15068391]
: +- *(3) Project [shardId#15068308, item#15068385.worklistShardItemId AS worklistShardItemId#15068386L, item#15068385.requestedQuantities AS requestedQuantities#15068389]
: +- *(3) Filter ((size(item#15068385.requestedQuantities, true) > 0) AND isnotnull(i...
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/22 20:36:42 | 0.2 s |
30/30
| 992.0 B | 3.9 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 3725796 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725795 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725794 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725793 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725792 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725791 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725790 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725789 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725788 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725787 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725786 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725785 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725784 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725783 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725782 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725781 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725780 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725779 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725778 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725777 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725776 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725775 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725774 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725773 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725772 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725771 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725770 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725769 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725768 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725767 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725766 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725765 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725764 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725763 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725762 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725761 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725760 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725759 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725758 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725757 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725756 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725755 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725754 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725753 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725752 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725751 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725750 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725749 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725748 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725747 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725746 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725745 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725744 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725743 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725742 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725741 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725740 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725739 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725738 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725737 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725736 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725735 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725734 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725733 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725732 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725731 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725730 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725729 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725728 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725727 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725726 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725725 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725724 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725723 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725722 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725721 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725720 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725719 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725718 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725717 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725716 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725715 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725714 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725713 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725712 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725711 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725710 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725709 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725708 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725707 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725706 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725705 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725704 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725703 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 3725702 | Unknown Unknown | Unknown | Unknown |
0/0
|