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

Status: SUCCEEDED
Submitted: 2026/05/20 06:02:33
Duration: 5 s
Associated SQL Query: 64214
Job Group: a916795f-b51b-4479-8bfc-bf20af3490c9
Completed Stages: 7

Enable zooming

digraph G { id="graph_277695"; subgraph graph_stage_277695 { id="graph_stage_277695"; isCluster="true"; label="Stage 277695"; subgraph cluster_1992273 { id="cluster_1992273"; isCluster="true"; label="Scan parquet "; 786987 [id="node_786987" labelType="html" label="FileScanRDD [786987] start at FileStorageAdapterImpl.java:174}"]; 786988 [id="node_786988" labelType="html" label="MapPartitionsRDD [786988] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992269 { id="cluster_1992269"; isCluster="true"; label="WholeStageCodegen (9)"; 786989 [id="node_786989" labelType="html" label="MapPartitionsRDD [786989] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992268 { id="cluster_1992268"; isCluster="true"; label="Exchange"; 786990 [id="node_786990" labelType="html" label="MapPartitionsRDD [786990] start at FileStorageAdapterImpl.java:174}"]; } } 786987->786988; 786988->786989; 786989->786990; }

digraph G { id="graph_277696"; subgraph graph_stage_277696 { id="graph_stage_277696"; isCluster="true"; label="Stage 277696"; subgraph cluster_1992240 { id="cluster_1992240"; isCluster="true"; label="Scan parquet "; 786971 [id="node_786971" labelType="html" label="FileScanRDD [786971] start at FileStorageAdapterImpl.java:174}"]; 786972 [id="node_786972" labelType="html" label="MapPartitionsRDD [786972] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992236 { id="cluster_1992236"; isCluster="true"; label="WholeStageCodegen (3)"; 786973 [id="node_786973" labelType="html" label="MapPartitionsRDD [786973] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992235 { id="cluster_1992235"; isCluster="true"; label="Exchange"; 786974 [id="node_786974" labelType="html" label="MapPartitionsRDD [786974] start at FileStorageAdapterImpl.java:174}"]; } } 786971->786972; 786972->786973; 786973->786974; }

digraph G { id="graph_277697"; subgraph graph_stage_277697 { id="graph_stage_277697"; isCluster="true"; label="Stage 277697"; subgraph cluster_1992224 { id="cluster_1992224"; isCluster="true"; label="Scan parquet "; 786965 [id="node_786965" labelType="html" label="FileScanRDD [786965] start at FileStorageAdapterImpl.java:174}"]; 786966 [id="node_786966" labelType="html" label="MapPartitionsRDD [786966] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992220 { id="cluster_1992220"; isCluster="true"; label="WholeStageCodegen (1)"; 786967 [id="node_786967" labelType="html" label="MapPartitionsRDD [786967] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992219 { id="cluster_1992219"; isCluster="true"; label="Exchange"; 786968 [id="node_786968" labelType="html" label="MapPartitionsRDD [786968] start at FileStorageAdapterImpl.java:174}"]; } } 786965->786966; 786966->786967; 786967->786968; }

digraph G { id="graph_277698"; subgraph graph_stage_277698 { id="graph_stage_277698"; isCluster="true"; label="Stage 277698"; subgraph cluster_1992219 { id="cluster_1992219"; isCluster="true"; label="Exchange"; 786969 [id="node_786969" labelType="html" label="ShuffledRowRDD [786969] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992215 { id="cluster_1992215"; isCluster="true"; label="WholeStageCodegen (2)"; 786970 [id="node_786970" labelType="html" label="MapPartitionsRDD [786970] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992235 { id="cluster_1992235"; isCluster="true"; label="Exchange"; 786975 [id="node_786975" labelType="html" label="ShuffledRowRDD [786975] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992231 { id="cluster_1992231"; isCluster="true"; label="WholeStageCodegen (4)"; 786976 [id="node_786976" labelType="html" label="MapPartitionsRDD [786976] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992230 { id="cluster_1992230"; isCluster="true"; label="ObjectHashAggregate"; 786977 [id="node_786977" labelType="html" label="MapPartitionsRDD [786977] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992229 { id="cluster_1992229"; isCluster="true"; label="ObjectHashAggregate"; 786978 [id="node_786978" labelType="html" label="MapPartitionsRDD [786978] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992226 { id="cluster_1992226"; isCluster="true"; label="WholeStageCodegen (5)"; 786979 [id="node_786979" labelType="html" label="MapPartitionsRDD [786979] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992205 { id="cluster_1992205"; isCluster="true"; label="WholeStageCodegen (7)"; 786980 [id="node_786980" labelType="html" label="ZippedPartitionsRDD2 [786980] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 786981 [id="node_786981" labelType="html" label="MapPartitionsRDD [786981] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992204 { id="cluster_1992204"; isCluster="true"; label="Exchange"; 786982 [id="node_786982" labelType="html" label="MapPartitionsRDD [786982] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 786969->786970; 786975->786976; 786976->786977; 786977->786978; 786978->786979; 786970->786980; 786979->786980; 786980->786981; 786981->786982; }

786968,786969

786974,786975

digraph G { id="graph_277699"; subgraph graph_stage_277699 { id="graph_stage_277699"; isCluster="true"; label="Stage 277699"; subgraph cluster_1992268 { id="cluster_1992268"; isCluster="true"; label="Exchange"; 786991 [id="node_786991" labelType="html" label="ShuffledRowRDD [786991] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992246 { id="cluster_1992246"; isCluster="true"; label="WholeStageCodegen (13)"; 786992 [id="node_786992" labelType="html" label="MapPartitionsRDD [786992] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992245 { id="cluster_1992245"; isCluster="true"; label="Exchange"; 786993 [id="node_786993" labelType="html" label="MapPartitionsRDD [786993] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 786991->786992; 786992->786993; }

786990,786991

digraph G { id="graph_277700"; subgraph graph_stage_277700 { id="graph_stage_277700"; isCluster="true"; label="Stage 277700"; subgraph cluster_1992204 { id="cluster_1992204"; isCluster="true"; label="Exchange"; 786983 [id="node_786983" labelType="html" label="ShuffledRowRDD [786983] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992201 { id="cluster_1992201"; isCluster="true"; label="WholeStageCodegen (8)"; 786984 [id="node_786984" labelType="html" label="MapPartitionsRDD [786984] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992245 { id="cluster_1992245"; isCluster="true"; label="Exchange"; 786994 [id="node_786994" labelType="html" label="ShuffledRowRDD [786994] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992242 { id="cluster_1992242"; isCluster="true"; label="WholeStageCodegen (14)"; 786995 [id="node_786995" labelType="html" label="MapPartitionsRDD [786995] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992197 { id="cluster_1992197"; isCluster="true"; label="WholeStageCodegen (15)"; 786996 [id="node_786996" labelType="html" label="ZippedPartitionsRDD2 [786996] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 786997 [id="node_786997" labelType="html" label="MapPartitionsRDD [786997] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992196 { id="cluster_1992196"; isCluster="true"; label="ObjectHashAggregate"; 786998 [id="node_786998" labelType="html" label="MapPartitionsRDD [786998] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992195 { id="cluster_1992195"; isCluster="true"; label="Exchange"; 786999 [id="node_786999" labelType="html" label="MapPartitionsRDD [786999] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 786983->786984; 786994->786995; 786984->786996; 786995->786996; 786996->786997; 786997->786998; 786998->786999; }

786982,786983

786993,786994

digraph G { id="graph_277701"; subgraph graph_stage_277701 { id="graph_stage_277701"; isCluster="true"; label="Stage 277701"; 787008 [id="node_787008" labelType="html" label="SQLExecutionRDD [787008] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_1992195 { id="cluster_1992195"; isCluster="true"; label="Exchange"; 787000 [id="node_787000" labelType="html" label="ShuffledRowRDD [787000] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992194 { id="cluster_1992194"; isCluster="true"; label="ObjectHashAggregate"; 787001 [id="node_787001" labelType="html" label="MapPartitionsRDD [787001] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992193 { id="cluster_1992193"; isCluster="true"; label="Project"; 787002 [id="node_787002" labelType="html" label="MapPartitionsRDD [787002] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992172 { id="cluster_1992172"; isCluster="true"; label="WholeStageCodegen (18)"; 787003 [id="node_787003" labelType="html" label="MapPartitionsRDD [787003] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992171 { id="cluster_1992171"; isCluster="true"; label="DeserializeToObject"; 787004 [id="node_787004" labelType="html" label="MapPartitionsRDD [787004] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992170 { id="cluster_1992170"; isCluster="true"; label="MapPartitions"; 787005 [id="node_787005" labelType="html" label="MapPartitionsRDD [787005] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992123 { id="cluster_1992123"; isCluster="true"; label="WholeStageCodegen (21)"; 787006 [id="node_787006" labelType="html" label="MapPartitionsRDD [787006] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992107 { id="cluster_1992107"; isCluster="true"; label="DeserializeToObject"; 787007 [id="node_787007" labelType="html" label="MapPartitionsRDD [787007] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992281 { id="cluster_1992281"; isCluster="true"; label="mapPartitions"; 787009 [id="node_787009" labelType="html" label="MapPartitionsRDD [787009] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1992282 { id="cluster_1992282"; isCluster="true"; label="mapPartitions"; 787010 [id="node_787010" labelType="html" label="MapPartitionsRDD [787010] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 787000->787001; 787001->787002; 787002->787003; 787003->787004; 787004->787005; 787005->787006; 787006->787007; 787007->787008; 787008->787009; 787009->787010; }

786999,787000

787010

Completed Stages (7)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
277701	tenants-pool-562	stream-10000000265-1 id = 42e25fc0-d8ad-4b61-b7c3-ee524eefadc3 runId = a916795f-b51b-4479-8bfc-bf20af3490c9 batch = 104 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor896.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/05/20 06:02:37	0.7 s	30/30	11.5 KiB
277700	tenants-pool-562	stream-10000000265-1 id = 42e25fc0-d8ad-4b61-b7c3-ee524eefadc3 runId = a916795f-b51b-4479-8bfc-bf20af3490c9 batch = 104 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor896.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/05/20 06:02:36	0.8 s	30/30	21.0 KiB	11.5 KiB
277699	tenants-pool-562	stream-10000000265-1 id = 42e25fc0-d8ad-4b61-b7c3-ee524eefadc3 runId = a916795f-b51b-4479-8bfc-bf20af3490c9 batch = 104 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor896.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/05/20 06:02:34	0.8 s	30/30	20.5 KiB	2.2 KiB
277698	tenants-pool-562	stream-10000000265-1 id = 42e25fc0-d8ad-4b61-b7c3-ee524eefadc3 runId = a916795f-b51b-4479-8bfc-bf20af3490c9 batch = 104 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor896.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/05/20 06:02:35	0.3 s	30/30	136.7 KiB	18.8 KiB
277697	tenants-pool-562	stream-10000000265-1 id = 42e25fc0-d8ad-4b61-b7c3-ee524eefadc3 runId = a916795f-b51b-4479-8bfc-bf20af3490c9 batch = 104 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor896.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/05/20 06:02:33	0.7 s	29/29		46.5 KiB
277696	tenants-pool-562	stream-10000000265-1 id = 42e25fc0-d8ad-4b61-b7c3-ee524eefadc3 runId = a916795f-b51b-4479-8bfc-bf20af3490c9 batch = 104 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor896.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/05/20 06:02:33	3 s	33/33		90.2 KiB
277695	tenants-pool-562	stream-10000000265-1 id = 42e25fc0-d8ad-4b61-b7c3-ee524eefadc3 runId = a916795f-b51b-4479-8bfc-bf20af3490c9 batch = 104 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor896.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/05/20 06:02:33	0.7 s	29/29		20.5 KiB

Page: