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

Status: SUCCEEDED
Submitted: 2026/08/10 09:41:29
Duration: 0.3 s
Associated SQL Query: 837
Job Group: 3653a010-ae51-4869-9921-1deae7ee7835
Completed Stages: 1
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_3927"; subgraph graph_stage_3927 { id="graph_stage_3927"; isCluster="true"; label="Stage 3927"; 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_27166 { id="cluster_27166"; isCluster="true"; label="InMemoryTableScan"; 10064 [id="node_10064" labelType="html" label="MapPartitionsRDD [10064] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10066 [id="node_10066" labelType="html" label="MapPartitionsRDD [10066] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10067 [id="node_10067" labelType="html" label="MapPartitionsRDD [10067] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27153 { id="cluster_27153"; isCluster="true"; label="WholeStageCodegen (14)"; 10071 [id="node_10071" labelType="html" label="MapPartitionsRDD [10071] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27152 { id="cluster_27152"; isCluster="true"; label="ObjectHashAggregate"; 10072 [id="node_10072" labelType="html" label="MapPartitionsRDD [10072] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27151 { id="cluster_27151"; isCluster="true"; label="ObjectHashAggregate"; 10073 [id="node_10073" labelType="html" label="MapPartitionsRDD [10073] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27188 { id="cluster_27188"; isCluster="true"; label="InMemoryTableScan"; 10077 [id="node_10077" labelType="html" label="MapPartitionsRDD [10077] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10078 [id="node_10078" labelType="html" label="MapPartitionsRDD [10078] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 10079 [id="node_10079" labelType="html" label="MapPartitionsRDD [10079] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27179 { id="cluster_27179"; isCluster="true"; label="WholeStageCodegen (15)"; 10083 [id="node_10083" labelType="html" label="MapPartitionsRDD [10083] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27150 { id="cluster_27150"; isCluster="true"; label="Union"; 10084 [id="node_10084" labelType="html" label="UnionRDD [10084] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27137 { id="cluster_27137"; isCluster="true"; label="DeserializeToObject"; 10085 [id="node_10085" labelType="html" label="MapPartitionsRDD [10085] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 10019->10020; 10020->10021; 10021->10064; 10064->10066; 10066->10067; 10067->10071; 10071->10072; 10072->10073; 10021->10077; 10077->10078; 10078->10079; 10079->10083; 10073->10084; 10083->10084; 10084->10085; }

10018,10019

10021

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
3927	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.3 s	40/40	35.8 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3927

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.3 s

40/40

35.8 KiB

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: