No DAG visualization information to display for job 5034
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 96700 | tenants-pool-780 | stream-10000000347-1
id = 58eebb84-cfee-4087-b7b1-eb2de12d70e3
runId = 08a59b22-7060-442f-a3da-bada2bf2f5df
batch = 12 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) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/19 20:15:03 | 68 ms |
37/37
| 150.0 B | |||
| 96699 | tenants-pool-780 | stream-10000000347-1
id = 58eebb84-cfee-4087-b7b1-eb2de12d70e3
runId = 08a59b22-7060-442f-a3da-bada2bf2f5df
batch = 12 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) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/19 20:15:02 | 0.6 s |
74/74
| 777.0 B | 362.0 B | 150.0 B | |
| 96698 | tenants-pool-780 | stream-10000000347-1
id = 58eebb84-cfee-4087-b7b1-eb2de12d70e3
runId = 08a59b22-7060-442f-a3da-bada2bf2f5df
batch = 12 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) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/19 20:15:02 | 0.4 s |
74/74
| 65.4 KiB | 81.5 KiB | ||
| 96697 | tenants-pool-780 | stream-10000000347-1
id = 58eebb84-cfee-4087-b7b1-eb2de12d70e3
runId = 08a59b22-7060-442f-a3da-bada2bf2f5df
batch = 12 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) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/19 20:15:01 | 0.1 s |
37/37
| 1149.0 B | 362.0 B | ||
| 96695 | tenants-pool-780 | stream-10000000347-1
id = 58eebb84-cfee-4087-b7b1-eb2de12d70e3
runId = 08a59b22-7060-442f-a3da-bada2bf2f5df
batch = 12 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) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/19 20:15:01 | 0.2 s |
37/37
| 65.4 KiB | 160.7 KiB | ||
| 96694 | tenants-pool-780 | stream-10000000347-1
id = 58eebb84-cfee-4087-b7b1-eb2de12d70e3
runId = 08a59b22-7060-442f-a3da-bada2bf2f5df
batch = 12 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) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/19 20:15:01 | 0.2 s |
37/37
| ||||
| 96693 | tenants-pool-780 | stream-10000000347-1
id = 58eebb84-cfee-4087-b7b1-eb2de12d70e3
runId = 08a59b22-7060-442f-a3da-bada2bf2f5df
batch = 12 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) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.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/19 20:15:01 | 0.4 s |
37/37
| 65.4 KiB |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 96696 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96692 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96691 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96690 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96689 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96688 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96687 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96686 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96685 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96684 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96683 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96682 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96681 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96680 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96679 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96678 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96677 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96676 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96675 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96674 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96673 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96672 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96671 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96670 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96669 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96668 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96667 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96666 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96665 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96664 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96663 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96662 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96661 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96660 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96659 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96658 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96657 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96656 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96655 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96654 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96653 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96652 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96651 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96650 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96649 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96648 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96647 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96646 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96645 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96644 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96643 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96642 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96641 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96640 | Unknown Unknown | Unknown | Unknown |
0/0
| |||||
| 96639 | Unknown Unknown | Unknown | Unknown |
0/0
|