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

Status: SUCCEEDED
Submitted: 2026/07/21 18:07:43
Duration: 0.4 s
Associated SQL Query: 6518
Job Group: d96bf115-f542-4550-b53f-c6857f91a685
Completed Stages: 1
Skipped Stages: 1

Enable zooming

digraph G { id="graph_27765"; subgraph graph_stage_27765 { id="graph_stage_27765"; isCluster="true"; label="Stage 27765"; 77944 [id="node_77944" labelType="html" label="SQLExecutionRDD [77944] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_205490 { id="cluster_205490"; isCluster="true"; label="Scan parquet "; 77941 [id="node_77941" labelType="html" label="FileScanRDD [77941] start at FileStorageAdapterImpl.java:179}"]; 77942 [id="node_77942" labelType="html" label="MapPartitionsRDD [77942] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205487 { id="cluster_205487"; isCluster="true"; label="WholeStageCodegen (1)"; 77943 [id="node_77943" labelType="html" label="MapPartitionsRDD [77943] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205494 { id="cluster_205494"; isCluster="true"; label="WholeStageCodegen (1)"; 77945 [id="node_77945" labelType="html" label="MapPartitionsRDD [77945] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205493 { id="cluster_205493"; isCluster="true"; label="Exchange"; 77946 [id="node_77946" labelType="html" label="MapPartitionsRDD [77946] start at FileStorageAdapterImpl.java:179}"]; } } 77941->77942; 77942->77943; 77943->77944; 77944->77945; 77945->77946; }

digraph G { id="graph_27767"; subgraph graph_stage_27767 { id="graph_stage_27767"; isCluster="true"; label="Stage 27767"; subgraph cluster_205493 { id="cluster_205493"; isCluster="true"; label="Exchange"; 77947 [id="node_77947" labelType="html" label="ShuffledRowRDD [77947] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205492 { id="cluster_205492"; isCluster="true"; label="InMemoryTableScan"; 77948 [id="node_77948" labelType="html" label="MapPartitionsRDD [77948] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 77949 [id="node_77949" labelType="html" label="Exchange hashpartitioning(product#1310130, plant#1310131, 30), REPARTITION_BY_NUM, [plan_id=2204994]\n+- *(1) Scan ExistingRDD[shardId#1310127,worklistShardItemId#1310128L,version#1310129,product#1310130,plant#1310131,periodStart#1310132,periodEnd#1310133,qty#1310134]\n [77949] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205629 { id="cluster_205629"; isCluster="true"; label="InMemoryTableScan"; 77994 [id="node_77994" labelType="html" label="MapPartitionsRDD [77994] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 77995 [id="node_77995" labelType="html" label="MapPartitionsRDD [77995] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 77996 [id="node_77996" labelType="html" label="MapPartitionsRDD [77996] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205619 { id="cluster_205619"; isCluster="true"; label="WholeStageCodegen (14)"; 77999 [id="node_77999" labelType="html" label="MapPartitionsRDD [77999] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205618 { id="cluster_205618"; isCluster="true"; label="ObjectHashAggregate"; 78000 [id="node_78000" labelType="html" label="MapPartitionsRDD [78000] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205617 { id="cluster_205617"; isCluster="true"; label="ObjectHashAggregate"; 78001 [id="node_78001" labelType="html" label="MapPartitionsRDD [78001] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205650 { id="cluster_205650"; isCluster="true"; label="InMemoryTableScan"; 78005 [id="node_78005" labelType="html" label="MapPartitionsRDD [78005] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78006 [id="node_78006" labelType="html" label="MapPartitionsRDD [78006] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78007 [id="node_78007" labelType="html" label="MapPartitionsRDD [78007] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205643 { id="cluster_205643"; isCluster="true"; label="WholeStageCodegen (15)"; 78010 [id="node_78010" labelType="html" label="MapPartitionsRDD [78010] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205616 { id="cluster_205616"; isCluster="true"; label="Union"; 78012 [id="node_78012" labelType="html" label="UnionRDD [78012] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205601 { id="cluster_205601"; isCluster="true"; label="DeserializeToObject"; 78013 [id="node_78013" labelType="html" label="MapPartitionsRDD [78013] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 77947->77948; 77948->77949; 77949->77994; 77994->77995; 77995->77996; 77996->77999; 77999->78000; 78000->78001; 77949->78005; 78005->78006; 78006->78007; 78007->78010; 78001->78012; 78010->78012; 78012->78013; }

77946,77947

77949

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
27767	tenants-pool-562	stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 batch = 10 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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/07/21 18:07:43	0.3 s	60/60	17.5 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

27767

tenants-pool-562

stream-10000001127-1 id = 716dccd8-00fd-4bd0-80ff-071a254ffe2f runId = d96bf115-f542-4550-b53f-c6857f91a685 batch = 10 start at FileStorageAdapterImpl.java:179 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
jdk.internal.reflect.GeneratedMethodAccessor810.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:105)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76)
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/07/21 18:07:43

0.3 s

60/60

17.5 KiB

Page:

Skipped Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
27765	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor810.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:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) 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/10

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

27765

default

start at FileStorageAdapterImpl.java:179 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
jdk.internal.reflect.GeneratedMethodAccessor810.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:105)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76)
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/10

Page: