crp-order-quantity-kpi-service - Details for Job 311

Status: SUCCEEDED
Submitted: 2026/08/10 08:20:55
Duration: 0.8 s
Associated SQL Query: 165
Job Group: f6fc2d63-a255-4383-a46a-6581aeff922a
Completed Stages: 3

Enable zooming

digraph G { id="graph_928"; subgraph graph_stage_928 { id="graph_stage_928"; isCluster="true"; label="Stage 928"; 1897 [id="node_1897" labelType="html" label="SQLExecutionRDD [1897] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_4728 { id="cluster_4728"; isCluster="true"; label="Scan parquet "; 1894 [id="node_1894" labelType="html" label="FileScanRDD [1894] start at FileStorageAdapterImpl.java:177}"]; 1895 [id="node_1895" labelType="html" label="MapPartitionsRDD [1895] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4725 { id="cluster_4725"; isCluster="true"; label="WholeStageCodegen (1)"; 1896 [id="node_1896" labelType="html" label="MapPartitionsRDD [1896] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4732 { id="cluster_4732"; isCluster="true"; label="WholeStageCodegen (1)"; 1898 [id="node_1898" labelType="html" label="MapPartitionsRDD [1898] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4731 { id="cluster_4731"; isCluster="true"; label="Exchange"; 1899 [id="node_1899" labelType="html" label="MapPartitionsRDD [1899] start at FileStorageAdapterImpl.java:177}"]; } } 1894->1895; 1895->1896; 1896->1897; 1897->1898; 1898->1899; }

digraph G { id="graph_929"; subgraph graph_stage_929 { id="graph_stage_929"; isCluster="true"; label="Stage 929"; subgraph cluster_4731 { id="cluster_4731"; isCluster="true"; label="Exchange"; 1900 [id="node_1900" labelType="html" label="ShuffledRowRDD [1900] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4730 { id="cluster_4730"; isCluster="true"; label="InMemoryTableScan"; 1901 [id="node_1901" labelType="html" label="MapPartitionsRDD [1901] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1902 [id="node_1902" labelType="html" label="Exchange hashpartitioning(product#11, plant#12, 20), REPARTITION_BY_NUM, [plan_id=12417]\n+- *(1) Scan ExistingRDD[shardId#8,worklistShardItemId#9L,version#10,product#11,plant#12,periodStart#13,periodEnd#14,qty#15]\n [1902] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1903 [id="node_1903" labelType="html" label="MapPartitionsRDD [1903] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1904 [id="node_1904" labelType="html" label="MapPartitionsRDD [1904] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1905 [id="node_1905" labelType="html" label="MapPartitionsRDD [1905] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4729 { id="cluster_4729"; isCluster="true"; label="CollectLimit"; 1906 [id="node_1906" labelType="html" label="MapPartitionsRDD [1906] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1907 [id="node_1907" labelType="html" label="MapPartitionsRDD [1907] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1900->1901; 1901->1902; 1902->1903; 1903->1904; 1904->1905; 1905->1906; 1906->1907; }

1899,1900

1902

digraph G { id="graph_930"; subgraph graph_stage_930 { id="graph_stage_930"; isCluster="true"; label="Stage 930"; subgraph cluster_4729 { id="cluster_4729"; isCluster="true"; label="CollectLimit"; 1908 [id="node_1908" labelType="html" label="ShuffledRowRDD [1908] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1909 [id="node_1909" labelType="html" label="MapPartitionsRDD [1909] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4734 { id="cluster_4734"; isCluster="true"; label="mapPartitionsInternal"; 1910 [id="node_1910" labelType="html" label="MapPartitionsRDD [1910] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1908->1909; 1909->1910; }

1907,1908

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
930	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 8 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 08:20:56	7 ms	1/1
929	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 8 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 08:20:56	0.5 s	20/20	27.0 KiB	1240.0 B
928	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 8 start at FileStorageAdapterImpl.java:177 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) 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/08/10 08:20:55	0.3 s	19/19		27.0 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

930

tenants-pool-286

stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 8 start at FileStorageAdapterImpl.java:177 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
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/08/10 08:20:56

7 ms

1/1

929

tenants-pool-286

stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 8 start at FileStorageAdapterImpl.java:177 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
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/08/10 08:20:56

0.5 s

20/20

27.0 KiB

1240.0 B

928

tenants-pool-286

stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 8 start at FileStorageAdapterImpl.java:177 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:177)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
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:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
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/08/10 08:20:55

0.3 s

19/19

27.0 KiB

Page: