No DAG visualization information to display for job 6495
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 118316 | tenants-pool-780 | stream-10000000350-1
id = dc642002-2b52-4744-bf90-967729f330bc
runId = 81faa882-918e-4a51-b5e3-3a01a5c048df
batch = 8 start at FileStorageAdapterImpl.java:171 org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) jdk.internal.reflect.GeneratedMethodAccessor1635.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:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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/03/21 01:18:00 | 65 ms |
37/37
| 2.2 KiB | |||
| 118315 | tenants-pool-780 | stream-10000000350-1
id = dc642002-2b52-4744-bf90-967729f330bc
runId = 81faa882-918e-4a51-b5e3-3a01a5c048df
batch = 8 start at FileStorageAdapterImpl.java:171
RDD: SortAggregate(key=[demandChannel#1153447, shardId#1100457, qty#1153467, worklistShardItemId#1100458L, demandStream#1153448], functions=[first(kpis#1153476, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1153467, demandChannel#1153447, demandStream#1153448, kpis#1153609])
+- *(6) Sort [demandChannel#1153447 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1153467 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1153448 ASC NULLS FIRST], false, 0
+- Exchange hashpartitioning(demandChannel#1153447, shardId#1100457, qty#1153467, worklistShardItemId#1100458L, demandStream#1153448, 37), ENSURE_REQUIREMENTS, [plan_id=1762616]
+- SortAggregate(key=[demandChannel#1153447, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1153467)) AS qty#1153467, worklistShardItemId#1100458L, demandStream#1153448], functions=[partial_first(kpis#1153476, false)], output=[demandChannel#1153447, shardId#1100457, qty#1153467, worklistShardItemId#1100458L,...
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) jdk.internal.reflect.GeneratedMethodAccessor1635.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:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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/03/21 01:18:00 | 0.2 s |
37/37
| 14.0 KiB | 2.2 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 118314 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118313 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118312 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118311 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118310 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118309 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118308 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118307 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118306 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118305 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118304 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118303 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118302 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118301 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118300 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118299 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118298 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118297 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118296 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118295 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118294 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118293 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118292 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118291 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118290 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118289 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118288 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118287 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118286 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118285 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118284 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118283 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118282 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118281 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118280 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118279 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118278 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118277 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118276 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118275 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118274 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118273 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118272 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118271 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118270 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118269 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118268 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118267 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118266 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118265 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118264 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118263 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118262 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118261 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118260 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118259 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118258 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118257 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118256 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118255 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118254 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118253 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118252 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118251 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118250 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118249 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118248 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118247 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118246 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118245 | Unknown Unknown | Unknown | Unknown |
0/0
|