No DAG visualization information to display for job 56564
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1575881 | tenants-pool-679 | stream-10000002290-1
id = 9de6f34f-766f-4f9e-a20a-4d04550271a4
runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02
batch = 50 start at FileStorageAdapterImpl.java:598 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:22:23 | 21 ms |
1/1
| 2.1 KiB | |||
| 1575880 | tenants-pool-679 | stream-10000002290-1
id = 9de6f34f-766f-4f9e-a20a-4d04550271a4
runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02
batch = 50 start at FileStorageAdapterImpl.java:598
RDD: ObjectHashAggregate(keys=[shardId#6608407, resultSeparationId#6612302L], functions=[collect_list(orderProposal#6610550, 0, 0)], output=[shardId#6608407, resultSeparationId#6612302L, orderProposals#6612306])
+- Exchange hashpartitioning(shardId#6608407, resultSeparationId#6612302L, 30), ENSURE_REQUIREMENTS, [plan_id=3474009]
+- ObjectHashAggregate(keys=[shardId#6608407, resultSeparationId#6612302L], functions=[partial_collect_list(orderProposal#6610550, 0, 0)], output=[shardId#6608407, resultSeparationId#6612302L, buf#6612342])
+- Project [shardId#6608407, orderProposal#6610550, CASE WHEN (size(orderProposal#6610550.parentItems, true) > 2000) THEN xxhash64(orderProposal#6610550.orderProposalId, 42) ELSE xxhash64(pmod(cast(orderProposal#6610550.orderProposalId as decimal(20,0)), 0), 42) END AS resultSeparationId#6612302L]
+- InMemoryTableScan [orderProposal#6610550, shardId#6608407]
+- InMemoryRelation [shardId#6608407, orderProposal#6610550], StorageLevel(disk, memory, 2 rep...
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:22:23 | 71 ms |
30/30
| 2.1 KiB | |||
| 1575879 | tenants-pool-679 | stream-10000002290-1
id = 9de6f34f-766f-4f9e-a20a-4d04550271a4
runId = 8fdff9a8-5e79-4dc5-83bf-49d519329d02
batch = 50 start at FileStorageAdapterImpl.java:598
RDD: Project [shardId#6608407, named_struct(orderProposalId, _extract_orderProposalId#6611198L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#6611190L, supplierGroup, _extract_supplierGroup#6611191, optimizationGroups, coalesce(optimizationGroups#6610443, []), supplier, _extract_supplier#6611192, supplyingPlant, _extract_supplyingPlant#6611193, orderDateTime, _extract_orderDateTime#6611194, itemGroups, _extract_itemGroups#6611195, previousOrderProposals, _extract_previousOrderProposals#6611196, parentItems, _extract_parentItems#6611197) AS orderProposal#6610550]
+- SortMergeJoin [coalesce(shardId#6608407, ), isnull(shardId#6608407), coalesce(_extract_orderProposalId#6611198L, 0), isnull(_extract_orderProposalId#6611198L)], [coalesce(shardId#6610446, ), isnull(shardId#6610446), coalesce(orderProposalId#6610447L, 0), isnull(orderProposalId#6610447L)], LeftOuter
:- Sort [coalesce(shardId#6608407, ) ASC NULLS FIRST, isnull(shardId#6608407) ASC NULLS FIRST, coalesce(_extract_orderProposalId#6611...
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:22:23 | 0.3 s |
30/30
| 630.0 B |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1575878 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575877 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575876 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575875 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575874 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575873 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575872 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575871 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575870 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575869 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575868 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575867 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575866 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575865 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575864 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575863 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575862 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575861 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575860 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575859 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575858 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575857 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575856 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575855 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575854 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575853 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575852 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575851 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575850 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575849 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575848 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575847 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575846 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575845 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575844 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575843 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575842 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575841 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575840 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575839 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575838 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575837 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575836 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575835 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575834 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575833 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575832 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575831 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575830 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575829 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575828 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575827 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575826 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575825 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575824 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575823 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575822 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575821 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575820 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575819 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575818 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575817 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575816 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575815 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575814 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575813 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575812 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575811 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575810 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575809 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575808 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575807 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575806 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575805 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575804 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575803 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575802 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575801 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575800 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575799 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575798 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575797 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575796 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575795 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575794 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575793 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575792 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575791 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575790 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575789 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575788 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575787 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575786 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575785 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575784 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575783 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575782 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575781 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575780 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1575779 | Unknown Unknown | Unknown | Unknown |
0/0
|