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

Status: SUCCEEDED
Submitted: 2026/08/10 09:41:29
Duration: 0.4 s
Associated SQL Query: 837
Job Group: 3653a010-ae51-4869-9921-1deae7ee7835
Completed Stages: 2
Skipped Stages: 1

Enable zooming

digraph G { id="graph_3925"; subgraph graph_stage_3925 { id="graph_stage_3925"; isCluster="true"; label="Stage 3925"; 10016 [id="node_10016" labelType="html" label="SQLExecutionRDD [10016] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_27026 { id="cluster_27026"; isCluster="true"; label="Scan parquet "; 10013 [id="node_10013" labelType="html" label="FileScanRDD [10013] start at FileStorageAdapterImpl.java:177}"]; 10014 [id="node_10014" labelType="html" label="MapPartitionsRDD [10014] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27023 { id="cluster_27023"; isCluster="true"; label="WholeStageCodegen (1)"; 10015 [id="node_10015" labelType="html" label="MapPartitionsRDD [10015] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27030 { id="cluster_27030"; isCluster="true"; label="WholeStageCodegen (1)"; 10017 [id="node_10017" labelType="html" label="MapPartitionsRDD [10017] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27029 { id="cluster_27029"; isCluster="true"; label="Exchange"; 10018 [id="node_10018" labelType="html" label="MapPartitionsRDD [10018] start at FileStorageAdapterImpl.java:177}"]; } } 10013->10014; 10014->10015; 10015->10016; 10016->10017; 10017->10018; }

digraph G { id="graph_3928"; subgraph graph_stage_3928 { id="graph_stage_3928"; isCluster="true"; label="Stage 3928"; subgraph cluster_27029 { id="cluster_27029"; isCluster="true"; label="Exchange"; 10019 [id="node_10019" labelType="html" label="ShuffledRowRDD [10019] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27028 { id="cluster_27028"; isCluster="true"; label="InMemoryTableScan"; 10020 [id="node_10020" labelType="html" label="MapPartitionsRDD [10020] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10021 [id="node_10021" labelType="html" label="Exchange hashpartitioning(product#142284, plant#142285, 20), REPARTITION_BY_NUM, [plan_id=315249]\n+- *(1) Scan ExistingRDD[shardId#142281,worklistShardItemId#142282L,version#142283,product#142284,plant#142285,periodStart#142286,periodEnd#142287,qty#142288]\n [10021] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27185 { id="cluster_27185"; isCluster="true"; label="InMemoryTableScan"; 10074 [id="node_10074" labelType="html" label="MapPartitionsRDD [10074] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10075 [id="node_10075" labelType="html" label="MapPartitionsRDD [10075] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10076 [id="node_10076" labelType="html" label="MapPartitionsRDD [10076] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27172 { id="cluster_27172"; isCluster="true"; label="WholeStageCodegen (17)"; 10080 [id="node_10080" labelType="html" label="MapPartitionsRDD [10080] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27171 { id="cluster_27171"; isCluster="true"; label="Exchange"; 10081 [id="node_10081" labelType="html" label="MapPartitionsRDD [10081] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 10019->10020; 10020->10021; 10021->10074; 10074->10075; 10075->10076; 10076->10080; 10080->10081; }

10018,10019

10021

digraph G { id="graph_3929"; subgraph graph_stage_3929 { id="graph_stage_3929"; isCluster="true"; label="Stage 3929"; subgraph cluster_27171 { id="cluster_27171"; isCluster="true"; label="Exchange"; 10082 [id="node_10082" labelType="html" label="ShuffledRowRDD [10082] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27162 { id="cluster_27162"; isCluster="true"; label="WholeStageCodegen (18)"; 10086 [id="node_10086" labelType="html" label="MapPartitionsRDD [10086] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27137 { id="cluster_27137"; isCluster="true"; label="DeserializeToObject"; 10087 [id="node_10087" labelType="html" label="MapPartitionsRDD [10087] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 10082->10086; 10086->10087; }

10081,10082

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
3929	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6 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:41:29	0.1 s	20/20			1500.0 B
3928	tenants-pool-286	stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6 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:41:29	0.2 s	20/20	17.9 KiB			1500.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3929

tenants-pool-286

stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6 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:41:29

0.1 s

20/20

1500.0 B

3928

tenants-pool-286

stream-10000002108-1 id = b883148f-c57b-4a41-bef5-25fbde29ffbe runId = 3653a010-ae51-4869-9921-1deae7ee7835 batch = 6 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:41:29

0.2 s

20/20

17.9 KiB

1500.0 B

Page:

Skipped Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
3925	default	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)	Unknown	Unknown	0/19

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3925

default

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)

Unknown

0/19

Page: