No DAG visualization information to display for job 6475
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 117803 | tenants-pool-780 | stream-10000000350-1
id = dc642002-2b52-4744-bf90-967729f330bc
runId = 81faa882-918e-4a51-b5e3-3a01a5c048df
batch = 7 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:17:32 | 0.7 s |
37/37
| 1845.9 KiB | |||
| 117802 | tenants-pool-780 | stream-10000000350-1
id = dc642002-2b52-4744-bf90-967729f330bc
runId = 81faa882-918e-4a51-b5e3-3a01a5c048df
batch = 7 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:16:41 | 51 s |
74/74
| 1889.5 KiB | 1845.9 KiB | ||
| 117801 | tenants-pool-780 | stream-10000000350-1
id = dc642002-2b52-4744-bf90-967729f330bc
runId = 81faa882-918e-4a51-b5e3-3a01a5c048df
batch = 7 start at FileStorageAdapterImpl.java:171
RDD: SortAggregate(key=[demandChannel#1147889, shardId#1100457, qty#1147909, worklistShardItemId#1100458L, demandStream#1147890], functions=[first(kpis#1147918, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1147909, demandChannel#1147889, demandStream#1147890, kpis#1148051])
+- *(6) Sort [demandChannel#1147889 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1147909 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1147890 ASC NULLS FIRST], false, 0
+- Exchange hashpartitioning(demandChannel#1147889, shardId#1100457, qty#1147909, worklistShardItemId#1100458L, demandStream#1147890, 37), ENSURE_REQUIREMENTS, [plan_id=1761067]
+- SortAggregate(key=[demandChannel#1147889, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1147909)) AS qty#1147909, worklistShardItemId#1100458L, demandStream#1147890], functions=[partial_first(kpis#1147918, false)], output=[demandChannel#1147889, shardId#1100457, qty#1147909, 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:16:39 | 2 s |
74/74
| 509.6 KiB | 1889.5 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 117800 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117799 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117798 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117797 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117796 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117795 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117794 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117793 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117792 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117791 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117790 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117789 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117788 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117787 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117786 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117785 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117784 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117783 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117782 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117781 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117780 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117779 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117778 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117777 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117776 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117775 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117774 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117773 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117772 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117771 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117770 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117769 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117768 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117767 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117766 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117765 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117764 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117763 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117762 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117761 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117760 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117759 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117758 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117757 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117756 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117755 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117754 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117753 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117752 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117751 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117750 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 117749 | Unknown Unknown | Unknown | Unknown |
0/0
|