No DAG visualization information to display for job 56526
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1573789 | tenants-pool-679 | stream-10000002290-1
id = 9de6f34f-766f-4f9e-a20a-4d04550271a4
runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02
batch = 49 start at FileStorageAdapterImpl.java:598
RDD: MapPartitionsRDD*(3) Project [shardId#6605741, worklistShardItemId#6605819L, version#6605828, product#6605889, plant#6605884, availabilityDateTime#6605891 AS periodStart#6605928, nextAvailabilityDateTime#6605892 AS periodEnd#6605929, qty#6605824]
+- *(3) BroadcastHashJoin [worklistShardItemId#6605819L], [worklistShardItemId#6605903L], LeftOuter, BuildRight, (shardId#6605741 = 0_1_10000002290), false
:- *(3) Project [shardId#6605741, worklistShardItemId#6605819L, qty#6605824, element_at([14], ((cast(array_position([0_1_10000002290], shardId#6605741) as int) - 1) + 1), None, false) AS version#6605828]
: +- *(3) Generate explode(requestedQuantities#6605822), [shardId#6605741, worklistShardItemId#6605819L], false, [qty#6605824]
: +- *(3) Project [shardId#6605741, item#6605818.worklistShardItemId AS worklistShardItemId#6605819L, item#6605818.requestedQuantities AS requestedQuantities#6605822]
: +- *(3) Filter ((size(item#6605818.requestedQuantities, true) > 0) AND isnotnull(item#6605818.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/22 02:21:54 | 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 |
|---|---|---|---|---|---|---|---|---|---|
| 1573788 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573787 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573786 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573785 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573784 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573783 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573782 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573781 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573780 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573779 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573778 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573777 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573776 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573775 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573774 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573773 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573772 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573771 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573770 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573769 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573768 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573767 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573766 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573765 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573764 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573763 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573762 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573761 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573760 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573759 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573758 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573757 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573756 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573755 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573754 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573753 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573752 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573751 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573750 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573749 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573748 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573747 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573746 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573745 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573744 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573743 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573742 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573741 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573740 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573739 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573738 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573737 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573736 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573735 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573734 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573733 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573732 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573731 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573730 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573729 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573728 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573727 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573726 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573725 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573724 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573723 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573722 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573721 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573720 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573719 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573718 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573717 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573716 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573715 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573714 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573713 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573712 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573711 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573710 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573709 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573708 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573707 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573706 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573705 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573704 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573703 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573702 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573701 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573700 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573699 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573698 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573697 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573696 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573695 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573694 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573693 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573692 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573691 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573690 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1573689 | Unknown Unknown | Unknown | Unknown |
0/0
|