No DAG visualization information to display for job 6496
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 118389 | 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:52 | 0.8 s |
37/37
| 1849.2 KiB | |||
| 118388 | 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:01 | 51 s |
74/74
| 1854.7 KiB | 1849.2 KiB | ||
| 118387 | 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 | 1 s |
74/74
| 508.1 KiB | 1854.7 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 118386 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118385 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118384 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118383 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118382 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118381 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118380 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118379 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118378 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118377 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118376 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118375 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118374 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118373 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118372 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118371 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118370 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118369 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118368 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118367 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118366 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118365 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118364 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118363 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118362 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118361 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118360 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118359 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118358 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118357 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118356 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118355 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118354 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118353 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118352 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118351 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118350 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118349 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118348 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118347 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118346 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118345 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118344 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118343 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118342 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118341 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118340 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118339 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118338 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118337 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118336 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118335 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118334 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118333 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118332 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118331 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118330 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118329 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118328 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118327 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118326 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118325 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118324 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118323 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118322 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118321 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118320 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118319 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118318 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 118317 | Unknown Unknown | Unknown | Unknown |
0/0
|