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

Status: SUCCEEDED
Submitted: 2026/07/21 20:59:06
Duration: 0.9 s
Associated SQL Query: 38772
Job Group: 7e223599-2bbc-4b04-bb19-188f6b84ba3d
Completed Stages: 1
Skipped Stages: 4

Enable zooming

digraph G { id="graph_173303"; subgraph graph_stage_173303 { id="graph_stage_173303"; isCluster="true"; label="Stage 173303 (skipped)"; subgraph cluster_1244088 { id="cluster_1244088"; isCluster="true"; label="LocalTableScan"; 483977 [id="node_483977" labelType="html" label="ParallelCollectionRDD [483977] start at FileStorageAdapterImpl.java:179}"]; 483979 [id="node_483979" labelType="html" label="MapPartitionsRDD [483979] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244087 { id="cluster_1244087"; isCluster="true"; label="Exchange"; 483980 [id="node_483980" labelType="html" label="MapPartitionsRDD [483980] start at FileStorageAdapterImpl.java:179}"]; } } 483977->483979; 483979->483980; }

digraph G { id="graph_173304"; subgraph graph_stage_173304 { id="graph_stage_173304"; isCluster="true"; label="Stage 173304 (skipped)"; subgraph cluster_1244085 { id="cluster_1244085"; isCluster="true"; label="LocalTableScan"; 483983 [id="node_483983" labelType="html" label="ParallelCollectionRDD [483983] start at FileStorageAdapterImpl.java:179}"]; 483984 [id="node_483984" labelType="html" label="MapPartitionsRDD [483984] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244084 { id="cluster_1244084"; isCluster="true"; label="Exchange"; 483985 [id="node_483985" labelType="html" label="MapPartitionsRDD [483985] start at FileStorageAdapterImpl.java:179}"]; } } 483983->483984; 483984->483985; }

digraph G { id="graph_173305"; subgraph graph_stage_173305 { id="graph_stage_173305"; isCluster="true"; label="Stage 173305 (skipped)"; subgraph cluster_1244101 { id="cluster_1244101"; isCluster="true"; label="AQEShuffleRead"; 483986 [id="node_483986" labelType="html" label="ShuffledRowRDD [483986] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244098 { id="cluster_1244098"; isCluster="true"; label="WholeStageCodegen (1)"; 483987 [id="node_483987" labelType="html" label="MapPartitionsRDD [483987] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244106 { id="cluster_1244106"; isCluster="true"; label="AQEShuffleRead"; 483988 [id="node_483988" labelType="html" label="ShuffledRowRDD [483988] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244103 { id="cluster_1244103"; isCluster="true"; label="WholeStageCodegen (2)"; 483989 [id="node_483989" labelType="html" label="MapPartitionsRDD [483989] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244094 { id="cluster_1244094"; isCluster="true"; label="WholeStageCodegen (3)"; 483990 [id="node_483990" labelType="html" label="ZippedPartitionsRDD2 [483990] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483991 [id="node_483991" labelType="html" label="MapPartitionsRDD [483991] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244093 { id="cluster_1244093"; isCluster="true"; label="Exchange"; 483992 [id="node_483992" labelType="html" label="MapPartitionsRDD [483992] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483986->483987; 483988->483989; 483987->483990; 483989->483990; 483990->483991; 483991->483992; }

483985,483986

483980,483988

digraph G { id="graph_173306"; subgraph graph_stage_173306 { id="graph_stage_173306"; isCluster="true"; label="Stage 173306 (skipped)"; subgraph cluster_1244091 { id="cluster_1244091"; isCluster="true"; label="LocalTableScan"; 483978 [id="node_483978" labelType="html" label="ParallelCollectionRDD [483978] start at FileStorageAdapterImpl.java:179}"]; 483981 [id="node_483981" labelType="html" label="MapPartitionsRDD [483981] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244090 { id="cluster_1244090"; isCluster="true"; label="Exchange"; 483982 [id="node_483982" labelType="html" label="MapPartitionsRDD [483982] start at FileStorageAdapterImpl.java:179}"]; } } 483978->483981; 483981->483982; }

digraph G { id="graph_173307"; subgraph graph_stage_173307 { id="graph_stage_173307"; isCluster="true"; label="Stage 173307"; subgraph cluster_1244116 { id="cluster_1244116"; isCluster="true"; label="AQEShuffleRead"; 483993 [id="node_483993" labelType="html" label="ShuffledRowRDD [483993] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244113 { id="cluster_1244113"; isCluster="true"; label="WholeStageCodegen (4)"; 483994 [id="node_483994" labelType="html" label="MapPartitionsRDD [483994] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244121 { id="cluster_1244121"; isCluster="true"; label="AQEShuffleRead"; 483995 [id="node_483995" labelType="html" label="ShuffledRowRDD [483995] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244118 { id="cluster_1244118"; isCluster="true"; label="WholeStageCodegen (5)"; 483996 [id="node_483996" labelType="html" label="MapPartitionsRDD [483996] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244108 { id="cluster_1244108"; isCluster="true"; label="WholeStageCodegen (6)"; 483997 [id="node_483997" labelType="html" label="ZippedPartitionsRDD2 [483997] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483998 [id="node_483998" labelType="html" label="MapPartitionsRDD [483998] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244107 { id="cluster_1244107"; isCluster="true"; label="WriteFiles"; 483999 [id="node_483999" labelType="html" label="MapPartitionsRDD [483999] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483993->483994; 483995->483996; 483994->483997; 483996->483997; 483997->483998; 483998->483999; }

483992,483993

483982,483995

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
173307	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 102 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.GeneratedMethodAccessor711.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 20:59:06	0.9 s	1/1		36.4 KiB	8.6 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

173307

tenants-pool-169

stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 102 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.GeneratedMethodAccessor711.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 20:59:06

0.9 s

1/1

36.4 KiB

8.6 KiB

Page:

Skipped Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
173306	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.GeneratedMethodAccessor711.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/26
173305	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.GeneratedMethodAccessor711.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
173304	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.GeneratedMethodAccessor711.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/26
173303	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.GeneratedMethodAccessor711.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/26

Page: