No DAG visualization information to display for job 18638
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 337260 | tenants-pool-506 | stream-10000000532-1
id = e1173103-f818-4d2c-b463-7c331a0a318e
runId = 9672435e-271f-4f72-bc82-76031aa42a7a
batch = 20 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/08/31 14:20:24 | 17 ms |
1/1
| ||||
| 337259 | tenants-pool-506 | stream-10000000532-1
id = e1173103-f818-4d2c-b463-7c331a0a318e
runId = 9672435e-271f-4f72-bc82-76031aa42a7a
batch = 20 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/08/31 14:20:22 | 2 s |
90/90
| 14.8 MiB | 100.9 KiB | ||
| 337255 | tenants-pool-506 | stream-10000000532-1
id = e1173103-f818-4d2c-b463-7c331a0a318e
runId = 9672435e-271f-4f72-bc82-76031aa42a7a
batch = 20 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/08/31 14:20:22 | 60 ms |
30/30
| 628.5 KiB | 264.6 KiB | ||
| 337253 | tenants-pool-506 | stream-10000000532-1
id = e1173103-f818-4d2c-b463-7c331a0a318e
runId = 9672435e-271f-4f72-bc82-76031aa42a7a
batch = 20 start at FileStorageAdapterImpl.java:596
RDD: *(1) Filter (isnotnull(shardId#3579932) AND (shardId#3579932 = 0_7_10000000532))
+- *(1) Scan ExistingRDD[shardId#3579932,orderProposalId#3579933L,items#3579934,optimizationGroups#3579935,isOptimal#3579936,lastModified#3579937,optimizationInsights#3579938]
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/08/31 14:20:22 | 36 ms |
30/30
| 232.4 KiB | |||
| 337252 | tenants-pool-506 | stream-10000000532-1
id = e1173103-f818-4d2c-b463-7c331a0a318e
runId = 9672435e-271f-4f72-bc82-76031aa42a7a
batch = 20 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/08/31 14:20:22 | 0.7 s |
37/37
| 628.5 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 337258 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337257 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337256 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337254 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337251 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337250 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337237 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337236 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337235 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337234 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337233 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337232 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337231 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337230 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337229 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337228 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337227 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337226 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337225 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337224 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337223 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337222 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337221 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337220 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337219 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337218 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337217 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337216 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337215 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337214 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337213 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337212 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337211 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337210 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337209 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337208 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337207 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337206 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337205 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337204 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337203 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337202 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337201 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337200 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337199 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337198 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337197 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337196 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337195 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337194 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337193 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337192 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337191 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337190 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337189 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337188 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337187 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337186 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337185 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337184 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337183 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337182 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337181 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337180 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337179 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337178 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337177 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337176 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337175 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337174 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337173 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337172 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337171 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337170 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337169 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337168 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337167 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337166 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337165 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337164 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337163 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337162 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337161 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337160 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337159 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337158 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337157 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337156 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337155 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337154 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337153 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337152 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337151 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337150 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337149 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337148 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337147 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337146 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337145 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337144 | Unknown Unknown | Unknown | Unknown |
0/0
|