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

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

Enable zooming

digraph G { id="graph_844"; subgraph graph_stage_844 { id="graph_stage_844"; isCluster="true"; label="Stage 844"; 1640 [id="node_1640" labelType="html" label="SQLExecutionRDD [1640] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_4098 { id="cluster_4098"; isCluster="true"; label="Scan parquet "; 1637 [id="node_1637" labelType="html" label="FileScanRDD [1637] start at FileStorageAdapterImpl.java:177}"]; 1638 [id="node_1638" labelType="html" label="MapPartitionsRDD [1638] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4095 { id="cluster_4095"; isCluster="true"; label="WholeStageCodegen (1)"; 1639 [id="node_1639" labelType="html" label="MapPartitionsRDD [1639] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4102 { id="cluster_4102"; isCluster="true"; label="WholeStageCodegen (1)"; 1641 [id="node_1641" labelType="html" label="MapPartitionsRDD [1641] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4101 { id="cluster_4101"; isCluster="true"; label="Exchange"; 1642 [id="node_1642" labelType="html" label="MapPartitionsRDD [1642] start at FileStorageAdapterImpl.java:177}"]; } } 1637->1638; 1638->1639; 1639->1640; 1640->1641; 1641->1642; }

digraph G { id="graph_845"; subgraph graph_stage_845 { id="graph_stage_845"; isCluster="true"; label="Stage 845"; subgraph cluster_4101 { id="cluster_4101"; isCluster="true"; label="Exchange"; 1643 [id="node_1643" labelType="html" label="ShuffledRowRDD [1643] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4100 { id="cluster_4100"; isCluster="true"; label="InMemoryTableScan"; 1644 [id="node_1644" labelType="html" label="MapPartitionsRDD [1644] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1645 [id="node_1645" labelType="html" label="Exchange hashpartitioning(product#11, plant#12, 20), REPARTITION_BY_NUM, [plan_id=10740]\n+- *(1) Scan ExistingRDD[shardId#8,worklistShardItemId#9L,version#10,product#11,plant#12,periodStart#13,periodEnd#14,qty#15]\n [1645] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1646 [id="node_1646" labelType="html" label="MapPartitionsRDD [1646] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1647 [id="node_1647" labelType="html" label="MapPartitionsRDD [1647] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1648 [id="node_1648" labelType="html" label="MapPartitionsRDD [1648] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4099 { id="cluster_4099"; isCluster="true"; label="CollectLimit"; 1649 [id="node_1649" labelType="html" label="MapPartitionsRDD [1649] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1650 [id="node_1650" labelType="html" label="MapPartitionsRDD [1650] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1643->1644; 1644->1645; 1645->1646; 1646->1647; 1647->1648; 1648->1649; 1649->1650; }

1642,1643

1645

digraph G { id="graph_846"; subgraph graph_stage_846 { id="graph_stage_846"; isCluster="true"; label="Stage 846"; subgraph cluster_4099 { id="cluster_4099"; isCluster="true"; label="CollectLimit"; 1651 [id="node_1651" labelType="html" label="ShuffledRowRDD [1651] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 1652 [id="node_1652" labelType="html" label="MapPartitionsRDD [1652] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_4104 { id="cluster_4104"; isCluster="true"; label="mapPartitionsInternal"; 1653 [id="node_1653" labelType="html" label="MapPartitionsRDD [1653] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 1651->1652; 1652->1653; }

1650,1651

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
846	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 7 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:26	7 ms	1/1
845	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 7 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:25	0.4 s	20/20	126.8 KiB	1240.0 B
844	tenants-pool-286	stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 7 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:25	0.3 s	25/25		126.8 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

846

tenants-pool-286

stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 7 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:26

7 ms

1/1

845

tenants-pool-286

stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 7 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:25

0.4 s

20/20

126.8 KiB

1240.0 B

844

tenants-pool-286

stream-10000002105-1 id = 38418ff3-6e87-432f-8962-53d651dfd8c3 runId = f6fc2d63-a255-4383-a46a-6581aeff922a batch = 7 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:25

0.3 s

25/25

126.8 KiB

Page: