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

Status: SUCCEEDED
Submitted: 2026/07/21 18:07:52
Duration: 0.7 s
Associated SQL Query: 6530
Job Group: d96bf115-f542-4550-b53f-c6857f91a685
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_27823"; subgraph graph_stage_27823 { id="graph_stage_27823"; isCluster="true"; label="Stage 27823 (skipped)"; subgraph cluster_206011 { id="cluster_206011"; isCluster="true"; label="LocalTableScan"; 78154 [id="node_78154" labelType="html" label="ParallelCollectionRDD [78154] start at FileStorageAdapterImpl.java:179}"]; 78156 [id="node_78156" labelType="html" label="MapPartitionsRDD [78156] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_206010 { id="cluster_206010"; isCluster="true"; label="Exchange"; 78157 [id="node_78157" labelType="html" label="MapPartitionsRDD [78157] start at FileStorageAdapterImpl.java:179}"]; } } 78154->78156; 78156->78157; }

digraph G { id="graph_27824"; subgraph graph_stage_27824 { id="graph_stage_27824"; isCluster="true"; label="Stage 27824 (skipped)"; subgraph cluster_206008 { id="cluster_206008"; isCluster="true"; label="LocalTableScan"; 78160 [id="node_78160" labelType="html" label="ParallelCollectionRDD [78160] start at FileStorageAdapterImpl.java:179}"]; 78161 [id="node_78161" labelType="html" label="MapPartitionsRDD [78161] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_206007 { id="cluster_206007"; isCluster="true"; label="Exchange"; 78162 [id="node_78162" labelType="html" label="MapPartitionsRDD [78162] start at FileStorageAdapterImpl.java:179}"]; } } 78160->78161; 78161->78162; }

digraph G { id="graph_27825"; subgraph graph_stage_27825 { id="graph_stage_27825"; isCluster="true"; label="Stage 27825 (skipped)"; subgraph cluster_206024 { id="cluster_206024"; isCluster="true"; label="AQEShuffleRead"; 78163 [id="node_78163" labelType="html" label="ShuffledRowRDD [78163] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_206021 { id="cluster_206021"; isCluster="true"; label="WholeStageCodegen (1)"; 78164 [id="node_78164" labelType="html" label="MapPartitionsRDD [78164] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_206029 { id="cluster_206029"; isCluster="true"; label="AQEShuffleRead"; 78165 [id="node_78165" labelType="html" label="ShuffledRowRDD [78165] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_206026 { id="cluster_206026"; isCluster="true"; label="WholeStageCodegen (2)"; 78166 [id="node_78166" labelType="html" label="MapPartitionsRDD [78166] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_206017 { id="cluster_206017"; isCluster="true"; label="WholeStageCodegen (3)"; 78167 [id="node_78167" labelType="html" label="ZippedPartitionsRDD2 [78167] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78168 [id="node_78168" labelType="html" label="MapPartitionsRDD [78168] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_206016 { id="cluster_206016"; isCluster="true"; label="Exchange"; 78169 [id="node_78169" labelType="html" label="MapPartitionsRDD [78169] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 78163->78164; 78165->78166; 78164->78167; 78166->78167; 78167->78168; 78168->78169; }

78162,78163

78157,78165

digraph G { id="graph_27826"; subgraph graph_stage_27826 { id="graph_stage_27826"; isCluster="true"; label="Stage 27826 (skipped)"; subgraph cluster_206014 { id="cluster_206014"; isCluster="true"; label="LocalTableScan"; 78155 [id="node_78155" labelType="html" label="ParallelCollectionRDD [78155] start at FileStorageAdapterImpl.java:179}"]; 78158 [id="node_78158" labelType="html" label="MapPartitionsRDD [78158] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_206013 { id="cluster_206013"; isCluster="true"; label="Exchange"; 78159 [id="node_78159" labelType="html" label="MapPartitionsRDD [78159] start at FileStorageAdapterImpl.java:179}"]; } } 78155->78158; 78158->78159; }

digraph G { id="graph_27827"; subgraph graph_stage_27827 { id="graph_stage_27827"; isCluster="true"; label="Stage 27827"; subgraph cluster_206039 { id="cluster_206039"; isCluster="true"; label="AQEShuffleRead"; 78170 [id="node_78170" labelType="html" label="ShuffledRowRDD [78170] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_206036 { id="cluster_206036"; isCluster="true"; label="WholeStageCodegen (4)"; 78171 [id="node_78171" labelType="html" label="MapPartitionsRDD [78171] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_206044 { id="cluster_206044"; isCluster="true"; label="AQEShuffleRead"; 78172 [id="node_78172" labelType="html" label="ShuffledRowRDD [78172] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_206041 { id="cluster_206041"; isCluster="true"; label="WholeStageCodegen (5)"; 78173 [id="node_78173" labelType="html" label="MapPartitionsRDD [78173] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_206031 { id="cluster_206031"; isCluster="true"; label="WholeStageCodegen (6)"; 78174 [id="node_78174" labelType="html" label="ZippedPartitionsRDD2 [78174] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 78175 [id="node_78175" labelType="html" label="MapPartitionsRDD [78175] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_206030 { id="cluster_206030"; isCluster="true"; label="WriteFiles"; 78176 [id="node_78176" labelType="html" label="MapPartitionsRDD [78176] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 78170->78171; 78172->78173; 78171->78174; 78173->78174; 78174->78175; 78175->78176; }

78169,78170

78159,78172

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
27827	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:52	0.7 s	1/1		36.9 KiB	9.2 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

27827

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:52

0.7 s

1/1

36.9 KiB

9.2 KiB

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
27826	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/27
27825	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/1
27824	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/27
27823	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/27

Page: