No DAG visualization information to display for job 46166
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 896447 | tenants-pool-506 | stream-10000000538-1
id = 6a5f8344-c315-4fb0-b9ab-ad03d279ced3
runId = 98bbba2d-07a7-407d-a16c-88a130d13a5c
batch = 14 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 11:02:53 | 0.2 s |
30/30
| ||||
| 896446 | tenants-pool-506 | stream-10000000538-1
id = 6a5f8344-c315-4fb0-b9ab-ad03d279ced3
runId = 98bbba2d-07a7-407d-a16c-88a130d13a5c
batch = 14 start at FileStorageAdapterImpl.java:596
RDD: *(1) Filter (isnotnull(shardId#8912926) AND (shardId#8912926 = 0_7_10000000538))
+- *(1) Scan ExistingRDD[shardId#8912926,orderProposalId#8912927L,items#8912928,optimizationGroups#8912929,isOptimal#8912930,lastModified#8912931,optimizationInsights#8912932]
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 11:02:52 | 0.5 s |
30/30
| 630.0 B |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 896445 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896444 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896443 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896442 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896441 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896440 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896439 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896438 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896437 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896436 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896435 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896434 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896433 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896432 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896431 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896430 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896429 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896428 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896427 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896426 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896425 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896424 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896423 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896422 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896421 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896420 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896419 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896418 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896417 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896416 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896415 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896414 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896413 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896412 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896411 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896410 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896409 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 896408 | Unknown Unknown | Unknown | Unknown |
0/0
|