No DAG visualization information to display for job 52704
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1033021 | tenants-pool-506 | stream-10000000540-2
id = 386dabc1-f677-44f7-82d8-69fe99072c2c
runId = 1ebd557e-9283-4610-a07b-41d13bb785c5
batch = 31 start at FileStorageAdapterImpl.java:596 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/09/01 14:15:33 | 20 ms |
30/30
| 2.7 KiB | |||
| 1033020 | tenants-pool-506 | stream-10000000540-2
id = 386dabc1-f677-44f7-82d8-69fe99072c2c
runId = 1ebd557e-9283-4610-a07b-41d13bb785c5
batch = 31 start at FileStorageAdapterImpl.java:596 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/09/01 14:15:33 | 0.6 s |
30/30
| 18.6 MiB | 2.7 KiB | ||
| 1033019 | tenants-pool-506 | stream-10000000540-2
id = 386dabc1-f677-44f7-82d8-69fe99072c2c
runId = 1ebd557e-9283-4610-a07b-41d13bb785c5
batch = 31 start at FileStorageAdapterImpl.java:596 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/09/01 14:15:31 | 0.2 s |
30/30
| 137.7 KiB | 805.5 KiB | ||
| 1033018 | tenants-pool-506 | stream-10000000540-2
id = 386dabc1-f677-44f7-82d8-69fe99072c2c
runId = 1ebd557e-9283-4610-a07b-41d13bb785c5
batch = 31 start at FileStorageAdapterImpl.java:596
RDD: MapPartitionsRDD
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) 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/09/01 14:15:31 | 1 s |
30/30
| 94.9 MiB | 17.8 MiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 1033017 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033016 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033015 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033014 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033013 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033012 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033011 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033010 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033009 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033008 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033007 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033006 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033005 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033004 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033003 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033002 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033001 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1033000 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032999 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032998 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032997 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032996 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032995 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032994 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032993 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032992 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032991 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032990 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032989 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032988 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032987 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032986 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032985 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032984 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032983 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032982 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032981 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032980 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032979 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032978 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032977 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032976 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032975 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032974 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032973 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032972 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032971 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032970 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032969 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032968 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032967 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032966 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032965 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032964 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032963 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032962 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032961 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032960 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032959 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032958 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032957 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032956 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032955 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032954 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032953 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032952 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032951 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032950 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032949 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032948 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032947 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032946 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032945 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032944 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032943 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032942 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032941 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032940 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032939 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032938 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032937 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032936 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032935 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032934 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032933 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032932 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032931 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032930 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032929 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032928 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032927 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032926 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032925 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032924 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032923 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032922 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032921 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032920 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032919 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 1032918 | Unknown Unknown | Unknown | Unknown |
0/0
|