No DAG visualization information to display for job 6941
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 128634 | tenants-pool-780 | stream-10000000351-1
id = 61846efb-bf39-441e-8218-46744ddf0f0f
runId = 325a8812-9963-4820-9b32-c1b224f207b8
batch = 13 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 20:15:43 | 0.7 s |
37/37
| 286.7 KiB | |||
| 128633 | tenants-pool-780 | stream-10000000351-1
id = 61846efb-bf39-441e-8218-46744ddf0f0f
runId = 325a8812-9963-4820-9b32-c1b224f207b8
batch = 13 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 20:15:33 | 10 s |
74/74
| 283.6 KiB | 286.7 KiB | ||
| 128632 | tenants-pool-780 | stream-10000000351-1
id = 61846efb-bf39-441e-8218-46744ddf0f0f
runId = 325a8812-9963-4820-9b32-c1b224f207b8
batch = 13 start at FileStorageAdapterImpl.java:171
RDD: SortAggregate(key=[demandChannel#1247948, shardId#1167367, qty#1247968, worklistShardItemId#1167368L, demandStream#1247949], functions=[first(kpis#1247977, false)], output=[shardId#1167367, worklistShardItemId#1167368L, qty#1247968, demandChannel#1247948, demandStream#1247949, kpis#1248110])
+- *(6) Sort [demandChannel#1247948 ASC NULLS FIRST, shardId#1167367 ASC NULLS FIRST, qty#1247968 ASC NULLS FIRST, worklistShardItemId#1167368L ASC NULLS FIRST, demandStream#1247949 ASC NULLS FIRST], false, 0
+- Exchange hashpartitioning(demandChannel#1247948, shardId#1167367, qty#1247968, worklistShardItemId#1167368L, demandStream#1247949, 37), ENSURE_REQUIREMENTS, [plan_id=1829300]
+- SortAggregate(key=[demandChannel#1247948, shardId#1167367, knownfloatingpointnormalized(normalizenanandzero(qty#1247968)) AS qty#1247968, worklistShardItemId#1167368L, demandStream#1247949], functions=[partial_first(kpis#1247977, false)], output=[demandChannel#1247948, shardId#1167367, qty#1247968, worklistShardItemId#1167368L,...
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 20:15:33 | 0.8 s |
74/74
| 68.1 KiB | 283.6 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 128631 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128630 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128629 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128628 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128627 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128626 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128625 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128624 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128623 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128622 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128621 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128620 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128619 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128618 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128617 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128616 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128615 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128614 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128613 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128612 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128611 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128610 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128609 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128608 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128607 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128606 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128605 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128604 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128603 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128602 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128601 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128600 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128599 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128598 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128597 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128596 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128595 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128594 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128593 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128592 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128591 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128590 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128589 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128588 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128587 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128586 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128585 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128584 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128583 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128582 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128581 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128580 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128579 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128578 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128577 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128576 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128575 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128574 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128573 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128572 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128571 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128570 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128569 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128568 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128567 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128566 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128565 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128564 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128563 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128562 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128561 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128560 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128559 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128558 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128557 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128556 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128555 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128554 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128553 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128552 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128551 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128550 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128549 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128548 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128547 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128546 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128545 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 128544 | Unknown Unknown | Unknown | Unknown |
0/0
|