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

Status: SUCCEEDED
Submitted: 2026/07/21 20:58:58
Duration: 3 s
Associated SQL Query: 38756
Job Group: 7e223599-2bbc-4b04-bb19-188f6b84ba3d
Completed Stages: 6

Enable zooming

digraph G { id="graph_173264"; subgraph graph_stage_173264 { id="graph_stage_173264"; isCluster="true"; label="Stage 173264"; subgraph cluster_1243871 { id="cluster_1243871"; isCluster="true"; label="Scan parquet "; 483879 [id="node_483879" labelType="html" label="FileScanRDD [483879] start at FileStorageAdapterImpl.java:179}"]; 483880 [id="node_483880" labelType="html" label="MapPartitionsRDD [483880] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243867 { id="cluster_1243867"; isCluster="true"; label="WholeStageCodegen (1)"; 483881 [id="node_483881" labelType="html" label="MapPartitionsRDD [483881] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243866 { id="cluster_1243866"; isCluster="true"; label="Exchange"; 483882 [id="node_483882" labelType="html" label="MapPartitionsRDD [483882] start at FileStorageAdapterImpl.java:179}"]; } } 483879->483880; 483880->483881; 483881->483882; }

digraph G { id="graph_173265"; subgraph graph_stage_173265 { id="graph_stage_173265"; isCluster="true"; label="Stage 173265"; subgraph cluster_1243904 { id="cluster_1243904"; isCluster="true"; label="Scan parquet "; 483890 [id="node_483890" labelType="html" label="FileScanRDD [483890] start at FileStorageAdapterImpl.java:179}"]; 483891 [id="node_483891" labelType="html" label="MapPartitionsRDD [483891] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243900 { id="cluster_1243900"; isCluster="true"; label="WholeStageCodegen (7)"; 483892 [id="node_483892" labelType="html" label="MapPartitionsRDD [483892] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243899 { id="cluster_1243899"; isCluster="true"; label="Exchange"; 483893 [id="node_483893" labelType="html" label="MapPartitionsRDD [483893] start at FileStorageAdapterImpl.java:179}"]; } } 483890->483891; 483891->483892; 483892->483893; }

digraph G { id="graph_173266"; subgraph graph_stage_173266 { id="graph_stage_173266"; isCluster="true"; label="Stage 173266"; subgraph cluster_1243899 { id="cluster_1243899"; isCluster="true"; label="Exchange"; 483894 [id="node_483894" labelType="html" label="ShuffledRowRDD [483894] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243877 { id="cluster_1243877"; isCluster="true"; label="WholeStageCodegen (11)"; 483895 [id="node_483895" labelType="html" label="MapPartitionsRDD [483895] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243876 { id="cluster_1243876"; isCluster="true"; label="Exchange"; 483896 [id="node_483896" labelType="html" label="MapPartitionsRDD [483896] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483894->483895; 483895->483896; }

483893,483894

digraph G { id="graph_173267"; subgraph graph_stage_173267 { id="graph_stage_173267"; isCluster="true"; label="Stage 173267"; subgraph cluster_1243866 { id="cluster_1243866"; isCluster="true"; label="Exchange"; 483883 [id="node_483883" labelType="html" label="ShuffledRowRDD [483883] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243845 { id="cluster_1243845"; isCluster="true"; label="WholeStageCodegen (5)"; 483884 [id="node_483884" labelType="html" label="MapPartitionsRDD [483884] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243844 { id="cluster_1243844"; isCluster="true"; label="Exchange"; 483885 [id="node_483885" labelType="html" label="MapPartitionsRDD [483885] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483883->483884; 483884->483885; }

483882,483883

digraph G { id="graph_173268"; subgraph graph_stage_173268 { id="graph_stage_173268"; isCluster="true"; label="Stage 173268"; subgraph cluster_1243844 { id="cluster_1243844"; isCluster="true"; label="Exchange"; 483886 [id="node_483886" labelType="html" label="ShuffledRowRDD [483886] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243841 { id="cluster_1243841"; isCluster="true"; label="WholeStageCodegen (6)"; 483887 [id="node_483887" labelType="html" label="MapPartitionsRDD [483887] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243876 { id="cluster_1243876"; isCluster="true"; label="Exchange"; 483897 [id="node_483897" labelType="html" label="ShuffledRowRDD [483897] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243873 { id="cluster_1243873"; isCluster="true"; label="WholeStageCodegen (12)"; 483898 [id="node_483898" labelType="html" label="MapPartitionsRDD [483898] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243837 { id="cluster_1243837"; isCluster="true"; label="WholeStageCodegen (13)"; 483899 [id="node_483899" labelType="html" label="ZippedPartitionsRDD2 [483899] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483900 [id="node_483900" labelType="html" label="MapPartitionsRDD [483900] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243836 { id="cluster_1243836"; isCluster="true"; label="ObjectHashAggregate"; 483901 [id="node_483901" labelType="html" label="MapPartitionsRDD [483901] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243835 { id="cluster_1243835"; isCluster="true"; label="Exchange"; 483902 [id="node_483902" labelType="html" label="MapPartitionsRDD [483902] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483886->483887; 483897->483898; 483887->483899; 483898->483899; 483899->483900; 483900->483901; 483901->483902; }

483885,483886

483896,483897

digraph G { id="graph_173269"; subgraph graph_stage_173269 { id="graph_stage_173269"; isCluster="true"; label="Stage 173269"; 483911 [id="node_483911" labelType="html" label="SQLExecutionRDD [483911] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1243835 { id="cluster_1243835"; isCluster="true"; label="Exchange"; 483903 [id="node_483903" labelType="html" label="ShuffledRowRDD [483903] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243834 { id="cluster_1243834"; isCluster="true"; label="ObjectHashAggregate"; 483904 [id="node_483904" labelType="html" label="MapPartitionsRDD [483904] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243833 { id="cluster_1243833"; isCluster="true"; label="Project"; 483905 [id="node_483905" labelType="html" label="MapPartitionsRDD [483905] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243812 { id="cluster_1243812"; isCluster="true"; label="WholeStageCodegen (16)"; 483906 [id="node_483906" labelType="html" label="MapPartitionsRDD [483906] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243811 { id="cluster_1243811"; isCluster="true"; label="DeserializeToObject"; 483907 [id="node_483907" labelType="html" label="MapPartitionsRDD [483907] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243810 { id="cluster_1243810"; isCluster="true"; label="MapPartitions"; 483908 [id="node_483908" labelType="html" label="MapPartitionsRDD [483908] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243756 { id="cluster_1243756"; isCluster="true"; label="WholeStageCodegen (19)"; 483909 [id="node_483909" labelType="html" label="MapPartitionsRDD [483909] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243735 { id="cluster_1243735"; isCluster="true"; label="DeserializeToObject"; 483910 [id="node_483910" labelType="html" label="MapPartitionsRDD [483910] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243912 { id="cluster_1243912"; isCluster="true"; label="mapPartitions"; 483912 [id="node_483912" labelType="html" label="MapPartitionsRDD [483912] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243913 { id="cluster_1243913"; isCluster="true"; label="mapPartitions"; 483913 [id="node_483913" labelType="html" label="MapPartitionsRDD [483913] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483903->483904; 483904->483905; 483905->483906; 483906->483907; 483907->483908; 483908->483909; 483909->483910; 483910->483911; 483911->483912; 483912->483913; }

483902,483903

483913

Completed Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
173269	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:58:59	2 s	30/30	8.6 KiB
173268	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:58:58	0.6 s	30/30	12.6 KiB	8.6 KiB
173267	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:58:58	0.1 s	30/30	1988.9 KiB	12.2 KiB
173266	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:58:58	0.4 s	30/30	152.9 KiB	392.0 B
173265	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:58:58	0.4 s	26/26		152.9 KiB
173264	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:58:58	0.4 s	26/26		1988.9 KiB

Page: