No DAG visualization information to display for job 18645
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 337282 | tenants-pool-506 | stream-10000000532-2
id = e64f0263-c3bb-4763-91e4-c179b778340d
runId = 1a176cce-65e1-41cf-a934-767a2c6b038c
batch = 17 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:25 | 10 ms |
1/1
| ||||
| 337281 | tenants-pool-506 | stream-10000000532-2
id = e64f0263-c3bb-4763-91e4-c179b778340d
runId = 1a176cce-65e1-41cf-a934-767a2c6b038c
batch = 17 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 | 1 s |
90/90
| 43.5 MiB | 338.6 KiB | ||
| 337280 | tenants-pool-506 | stream-10000000532-2
id = e64f0263-c3bb-4763-91e4-c179b778340d
runId = 1a176cce-65e1-41cf-a934-767a2c6b038c
batch = 17 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 | 0.1 s |
30/30
| 1752.8 KiB | 670.4 KiB | ||
| 337278 | tenants-pool-506 | stream-10000000532-2
id = e64f0263-c3bb-4763-91e4-c179b778340d
runId = 1a176cce-65e1-41cf-a934-767a2c6b038c
batch = 17 start at FileStorageAdapterImpl.java:596
RDD: *(1) Filter (isnotnull(shardId#3580449) AND (shardId#3580449 = 0_3_10000000532))
+- *(1) Scan ExistingRDD[shardId#3580449,orderProposalId#3580450L,items#3580451,optimizationGroups#3580452,isOptimal#3580453,lastModified#3580454,optimizationInsights#3580455]
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:23 | 0.2 s |
30/30
| 668.8 KiB | |||
| 337272 | tenants-pool-506 | stream-10000000532-2
id = e64f0263-c3bb-4763-91e4-c179b778340d
runId = 1a176cce-65e1-41cf-a934-767a2c6b038c
batch = 17 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:23 | 0.7 s |
37/37
| 1752.8 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 337279 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337277 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337276 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337275 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337274 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 337273 | 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
|