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

Status: SUCCEEDED
Submitted: 2026/08/10 09:41:30
Duration: 56 ms
Associated SQL Query: 841
Job Group: 3653a010-ae51-4869-9921-1deae7ee7835
Completed Stages: 1
Skipped Stages: 1

Enable zooming

digraph G { id="graph_3936"; subgraph graph_stage_3936 { id="graph_stage_3936"; isCluster="true"; label="Stage 3936 (skipped)"; subgraph cluster_24486 { id="cluster_24486"; isCluster="true"; label="Scan json "; 8964 [id="node_8964" labelType="html" label="FileScanRDD [8964] start at FileStorageAdapterImpl.java:177}"]; 8965 [id="node_8965" labelType="html" label="MapPartitionsRDD [8965] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24483 { id="cluster_24483"; isCluster="true"; label="WholeStageCodegen (1)"; 8966 [id="node_8966" labelType="html" label="MapPartitionsRDD [8966] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24482 { id="cluster_24482"; isCluster="true"; label="Exchange"; 8967 [id="node_8967" labelType="html" label="MapPartitionsRDD [8967] start at FileStorageAdapterImpl.java:177}"]; } } 8964->8965; 8965->8966; 8966->8967; }

digraph G { id="graph_3937"; subgraph graph_stage_3937 { id="graph_stage_3937"; isCluster="true"; label="Stage 3937"; 8973 [id="node_8973" labelType="html" label="SQLExecutionRDD [8973] [Unordered] start at FileStorageAdapterImpl.java:177}"]; 8977 [id="node_8977" labelType="html" label="SQLExecutionRDD [8977] [Unordered] start at FileStorageAdapterImpl.java:177}"]; subgraph cluster_24482 { id="cluster_24482"; isCluster="true"; label="Exchange"; 8968 [id="node_8968" labelType="html" label="ShuffledRowRDD [8968] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24478 { id="cluster_24478"; isCluster="true"; label="WholeStageCodegen (2)"; 8969 [id="node_8969" labelType="html" label="MapPartitionsRDD [8969] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24477 { id="cluster_24477"; isCluster="true"; label="DeserializeToObject"; 8970 [id="node_8970" labelType="html" label="MapPartitionsRDD [8970] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24476 { id="cluster_24476"; isCluster="true"; label="MapPartitions"; 8971 [id="node_8971" labelType="html" label="MapPartitionsRDD [8971] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24473 { id="cluster_24473"; isCluster="true"; label="WholeStageCodegen (3)"; 8972 [id="node_8972" labelType="html" label="MapPartitionsRDD [8972] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24487 { id="cluster_24487"; isCluster="true"; label="map"; 8974 [id="node_8974" labelType="html" label="Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000002108/0_1_10000002108/_delta_log [8974] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24489 { id="cluster_24489"; isCluster="true"; label="WholeStageCodegen (1)"; 8975 [id="node_8975" labelType="html" label="MapPartitionsRDD [8975] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24488 { id="cluster_24488"; isCluster="true"; label="Project"; 8976 [id="node_8976" labelType="html" label="MapPartitionsRDD [8976] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_24492 { id="cluster_24492"; isCluster="true"; label="map"; 8978 [id="node_8978" labelType="html" label="Delta Table State with Stats #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000002108/0_1_10000002108/_delta_log [8978] [Cached] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27307 { id="cluster_27307"; isCluster="true"; label="WholeStageCodegen (1)"; 10115 [id="node_10115" labelType="html" label="MapPartitionsRDD [10115] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } subgraph cluster_27306 { id="cluster_27306"; isCluster="true"; label="Scan parquet "; 10116 [id="node_10116" labelType="html" label="MapPartitionsRDD [10116] [Unordered] start at FileStorageAdapterImpl.java:177}"]; } } 8968->8969; 8969->8970; 8970->8971; 8971->8972; 8972->8973; 8973->8974; 8974->8975; 8975->8976; 8976->8977; 8977->8978; 8978->10115; 10115->10116; }

8967,8968

8974

8978

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
3937	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 RDD: Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000002108/0_1_10000002108/_delta_log Delta Table State with Stats #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000002108/0_1_10000002108/_delta_log 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:30	51 ms	50/50	1438.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3937

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

RDD: Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000002108/0_1_10000002108/_delta_log Delta Table State with Stats #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000002108/0_1_10000002108/_delta_log

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

51 ms

50/50

1438.0 B

Page:

Skipped Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
3936	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/1

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

3936

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/1

Page: