No DAG visualization information to display for job 47319
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1343995 | tenants-pool-169 | stream-10000001445-1
id = 26c9c63a-530b-4359-9e14-1592a674aa0e
runId = 881110fc-a22e-43dd-9ef6-858dd65243b7
batch = 102 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/21 20:59:25 | 9 ms |
1/1
| 2.1 KiB | |||
| 1343994 | tenants-pool-169 | stream-10000001445-1
id = 26c9c63a-530b-4359-9e14-1592a674aa0e
runId = 881110fc-a22e-43dd-9ef6-858dd65243b7
batch = 102 start at FileStorageAdapterImpl.java:598
RDD: ObjectHashAggregate(keys=[shardId#5594062, resultSeparationId#5597941L], functions=[collect_list(orderProposal#5596205, 0, 0)], output=[shardId#5594062, resultSeparationId#5597941L, orderProposals#5597945])
+- Exchange hashpartitioning(shardId#5594062, resultSeparationId#5597941L, 30), ENSURE_REQUIREMENTS, [plan_id=2904443]
+- ObjectHashAggregate(keys=[shardId#5594062, resultSeparationId#5597941L], functions=[partial_collect_list(orderProposal#5596205, 0, 0)], output=[shardId#5594062, resultSeparationId#5597941L, buf#5597981])
+- Project [shardId#5594062, orderProposal#5596205, CASE WHEN (size(orderProposal#5596205.parentItems, true) > 2000) THEN xxhash64(orderProposal#5596205.orderProposalId, 42) ELSE xxhash64(pmod(cast(orderProposal#5596205.orderProposalId as decimal(20,0)), 0), 42) END AS resultSeparationId#5597941L]
+- InMemoryTableScan [orderProposal#5596205, shardId#5594062]
+- InMemoryRelation [shardId#5594062, orderProposal#5596205], 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/21 20:59:25 | 69 ms |
30/30
| 2.1 KiB | |||
| 1343993 | tenants-pool-169 | stream-10000001445-1
id = 26c9c63a-530b-4359-9e14-1592a674aa0e
runId = 881110fc-a22e-43dd-9ef6-858dd65243b7
batch = 102 start at FileStorageAdapterImpl.java:598
RDD: Project [shardId#5594062, named_struct(orderProposalId, _extract_orderProposalId#5596853L, originalReplenishmentRunId, _extract_originalReplenishmentRunId#5596845L, supplierGroup, _extract_supplierGroup#5596846, optimizationGroups, coalesce(optimizationGroups#5596098, []), supplier, _extract_supplier#5596847, supplyingPlant, _extract_supplyingPlant#5596848, orderDateTime, _extract_orderDateTime#5596849, itemGroups, _extract_itemGroups#5596850, previousOrderProposals, _extract_previousOrderProposals#5596851, parentItems, _extract_parentItems#5596852) AS orderProposal#5596205]
+- BroadcastHashJoin [coalesce(shardId#5594062, ), isnull(shardId#5594062), coalesce(_extract_orderProposalId#5596853L, 0), isnull(_extract_orderProposalId#5596853L)], [coalesce(shardId#5596101, ), isnull(shardId#5596101), coalesce(orderProposalId#5596102L, 0), isnull(orderProposalId#5596102L)], LeftOuter, BuildRight, false
:- Project [shardId#5594062, orderProposal#5596088.orderProposalId AS _extract_orderProposalId#5596844L, order...
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:59:25 | 0.3 s |
30/30
| 630.0 B |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1343992 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343991 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343990 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343989 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343988 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343987 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343986 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343985 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343984 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343983 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343982 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343981 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343980 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343979 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343978 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343977 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343976 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343975 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343974 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343973 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343972 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343971 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343970 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343969 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343968 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343967 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343966 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343965 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343964 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343963 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343962 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343961 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343960 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343959 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343958 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343957 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343956 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343955 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343954 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343953 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343952 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343951 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343950 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343949 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343948 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343947 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343946 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343945 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343944 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343943 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343942 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343941 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343940 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343939 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343938 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343937 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343936 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343935 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343934 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343933 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343932 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343931 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343930 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343929 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343928 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343927 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343926 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343925 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343924 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343923 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343922 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343921 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343920 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343919 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343918 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343917 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343916 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343915 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343914 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343913 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343912 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343911 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343910 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343909 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343908 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343907 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343906 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343905 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343904 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343903 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343902 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343901 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343900 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343899 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343898 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343897 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343896 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343895 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343894 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1343893 | Unknown Unknown | Unknown | Unknown |
0/0
|