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

Status: SUCCEEDED
Submitted: 2026/08/10 09:32:20
Duration: 1.0 s
Associated SQL Query: 672
Job Group: cd2b79e8-7be4-4311-b6ba-b3d3f3439555
Completed Stages: 3

Enable zooming

digraph G { id="graph_3145"; subgraph graph_stage_3145 { id="graph_stage_3145"; isCluster="true"; label="Stage 3145"; 8035 [id="node_8035" labelType="html" label="SQLExecutionRDD [8035] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_21368 { id="cluster_21368"; isCluster="true"; label="Scan parquet "; 8032 [id="node_8032" labelType="html" label="FileScanRDD [8032] start at FileStorageAdapterImpl.java:177}"]; 8033 [id="node_8033" labelType="html" label="MapPartitionsRDD [8033] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21365 { id="cluster_21365"; isCluster="true"; label="WholeStageCodegen (1)"; 8034 [id="node_8034" labelType="html" label="MapPartitionsRDD [8034] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21372 { id="cluster_21372"; isCluster="true"; label="WholeStageCodegen (1)"; 8036 [id="node_8036" labelType="html" label="MapPartitionsRDD [8036] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21371 { id="cluster_21371"; isCluster="true"; label="Exchange"; 8037 [id="node_8037" labelType="html" label="MapPartitionsRDD [8037] start at FileStorageAdapterImpl.java:177}"]; } } 8032->8033; 8033->8034; 8034->8035; 8035->8036; 8036->8037; }

digraph G { id="graph_3146"; subgraph graph_stage_3146 { id="graph_stage_3146"; isCluster="true"; label="Stage 3146"; subgraph cluster_21371 { id="cluster_21371"; isCluster="true"; label="Exchange"; 8038 [id="node_8038" labelType="html" label="ShuffledRowRDD [8038] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21370 { id="cluster_21370"; isCluster="true"; label="InMemoryTableScan"; 8039 [id="node_8039" labelType="html" label="MapPartitionsRDD [8039] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 8040 [id="node_8040" labelType="html" label="Exchange hashpartitioning(product#68294, plant#68295, 20), REPARTITION_BY_NUM, [plan_id=212983]\n+- *(1) Scan ExistingRDD[shardId#68291,worklistShardItemId#68292L,version#68293,product#68294,plant#68295,periodStart#68296,periodEnd#68297,qty#68298]\n [8040] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 8041 [id="node_8041" labelType="html" label="MapPartitionsRDD [8041] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 8042 [id="node_8042" labelType="html" label="MapPartitionsRDD [8042] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 8043 [id="node_8043" labelType="html" label="MapPartitionsRDD [8043] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21369 { id="cluster_21369"; isCluster="true"; label="CollectLimit"; 8044 [id="node_8044" labelType="html" label="MapPartitionsRDD [8044] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 8045 [id="node_8045" labelType="html" label="MapPartitionsRDD [8045] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 8038->8039; 8039->8040; 8040->8041; 8041->8042; 8042->8043; 8043->8044; 8044->8045; }

8037,8038

8040

digraph G { id="graph_3147"; subgraph graph_stage_3147 { id="graph_stage_3147"; isCluster="true"; label="Stage 3147"; subgraph cluster_21369 { id="cluster_21369"; isCluster="true"; label="CollectLimit"; 8046 [id="node_8046" labelType="html" label="ShuffledRowRDD [8046] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 8047 [id="node_8047" labelType="html" label="MapPartitionsRDD [8047] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_21374 { id="cluster_21374"; isCluster="true"; label="mapPartitionsInternal"; 8048 [id="node_8048" labelType="html" label="MapPartitionsRDD [8048] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 8046->8047; 8047->8048; }

8045,8046

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
3147	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 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 09:32:21	6 ms	1/1
3146	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 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 09:32:20	0.6 s	20/20	35.4 KiB	1240.0 B
3145	tenants-pool-286	stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 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 09:32:20	0.4 s	25/25		35.4 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3147

tenants-pool-286

stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 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 09:32:21

6 ms

1/1

3146

tenants-pool-286

stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 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 09:32:20

0.6 s

20/20

35.4 KiB

1240.0 B

3145

tenants-pool-286

stream-10000002107-1 id = 65750d0d-58b0-4102-b531-612de250d6eb runId = cd2b79e8-7be4-4311-b6ba-b3d3f3439555 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 09:32:20

0.4 s

25/25

35.4 KiB

Page: