No DAG visualization information to display for job 6537
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 119937 | tenants-pool-780 | stream-10000000350-1
id = dc642002-2b52-4744-bf90-967729f330bc
runId = 81faa882-918e-4a51-b5e3-3a01a5c048df
batch = 10 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:20:43 | 60 ms |
37/37
| 92.0 B | |||
| 119936 | tenants-pool-780 | stream-10000000350-1
id = dc642002-2b52-4744-bf90-967729f330bc
runId = 81faa882-918e-4a51-b5e3-3a01a5c048df
batch = 10 start at FileStorageAdapterImpl.java:171
RDD: SortAggregate(key=[demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L, demandStream#1164564], functions=[first(kpis#1164592, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1164583, demandChannel#1164563, demandStream#1164564, kpis#1164725])
+- *(6) Sort [demandChannel#1164563 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1164583 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1164564 ASC NULLS FIRST], false, 0
+- Exchange hashpartitioning(demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L, demandStream#1164564, 37), ENSURE_REQUIREMENTS, [plan_id=1765755]
+- SortAggregate(key=[demandChannel#1164563, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1164583)) AS qty#1164583, worklistShardItemId#1100458L, demandStream#1164564], functions=[partial_first(kpis#1164592, false)], output=[demandChannel#1164563, shardId#1100457, qty#1164583, 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:20:42 | 0.1 s |
37/37
| 1272.0 B | 92.0 B |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 119935 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119934 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119933 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119932 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119931 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119930 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119929 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119928 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119927 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119926 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119925 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119924 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119923 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119922 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119921 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119920 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119919 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119918 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119917 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119916 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119915 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119914 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119913 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119912 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119911 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119910 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119909 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119908 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119907 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119906 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119905 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119904 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119903 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119902 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119901 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119900 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119899 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119898 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119897 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119896 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119895 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119894 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119893 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119892 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119891 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119890 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119889 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119888 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119887 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119886 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119885 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119884 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119883 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119882 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119881 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119880 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119879 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119878 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119877 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119876 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119875 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119874 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119873 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119872 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119871 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119870 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119869 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119868 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119867 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119866 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119865 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119864 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119863 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119862 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119861 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119860 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119859 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119858 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119857 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119856 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119855 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119854 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119853 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119852 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119851 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119850 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119849 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119848 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119847 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119846 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119845 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119844 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119843 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119842 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119841 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119840 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119839 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119838 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119837 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 119836 | Unknown Unknown | Unknown | Unknown |
0/0
|