crp-order-qty-opt-service - Details for Job 42014

Status: SUCCEEDED
Submitted: 2026/05/22 09:42:00
Duration: 0.9 s
Associated SQL Query: 25195
Job Group: 65cb8160-40af-4a1d-9ef7-845fbd048abf
Completed Stages: 4

Enable zooming

digraph G { id="graph_1297467"; subgraph graph_stage_1297467 { id="graph_stage_1297467"; isCluster="true"; label="Stage 1297467"; 341096 [id="node_341096" labelType="html" label="SQLExecutionRDD [341096] start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_877436 { id="cluster_877436"; isCluster="true"; label="Scan parquet "; 341093 [id="node_341093" labelType="html" label="FileScanRDD [341093] start at FileStorageAdapterImpl.java:567}"]; 341094 [id="node_341094" labelType="html" label="MapPartitionsRDD [341094] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_877433 { id="cluster_877433"; isCluster="true"; label="WholeStageCodegen (1)"; 341095 [id="node_341095" labelType="html" label="MapPartitionsRDD [341095] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_877451 { id="cluster_877451"; isCluster="true"; label="WholeStageCodegen (1)"; 341097 [id="node_341097" labelType="html" label="MapPartitionsRDD [341097] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_877450 { id="cluster_877450"; isCluster="true"; label="HashAggregate"; 341098 [id="node_341098" labelType="html" label="MapPartitionsRDD [341098] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_877449 { id="cluster_877449"; isCluster="true"; label="Exchange"; 341099 [id="node_341099" labelType="html" label="MapPartitionsRDD [341099] start at FileStorageAdapterImpl.java:567}"]; } } 341093->341094; 341094->341095; 341095->341096; 341096->341097; 341097->341098; 341098->341099; }

digraph G { id="graph_1297468"; subgraph graph_stage_1297468 { id="graph_stage_1297468"; isCluster="true"; label="Stage 1297468"; subgraph cluster_877449 { id="cluster_877449"; isCluster="true"; label="Exchange"; 341100 [id="node_341100" labelType="html" label="ShuffledRowRDD [341100] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_877446 { id="cluster_877446"; isCluster="true"; label="WholeStageCodegen (2)"; 341101 [id="node_341101" labelType="html" label="MapPartitionsRDD [341101] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_877445 { id="cluster_877445"; isCluster="true"; label="Exchange"; 341102 [id="node_341102" labelType="html" label="MapPartitionsRDD [341102] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 341100->341101; 341101->341102; }

341099,341100

digraph G { id="graph_1297469"; subgraph graph_stage_1297469 { id="graph_stage_1297469"; isCluster="true"; label="Stage 1297469"; subgraph cluster_877445 { id="cluster_877445"; isCluster="true"; label="Exchange"; 341103 [id="node_341103" labelType="html" label="ShuffledRowRDD [341103] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_877444 { id="cluster_877444"; isCluster="true"; label="InMemoryTableScan"; 341104 [id="node_341104" labelType="html" label="MapPartitionsRDD [341104] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 341105 [id="node_341105" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#5661070L, 30), REPARTITION_BY_NUM, [plan_id=2682535]\n+- *(2) HashAggregate(keys=[demandChannel#5661073, shardId#5661069, kpis#5661075, version#5661071, qty#5661072, worklistShardItemId#5661070L, demandStream#5661074], functions=[], output=[shardId#5661069, worklistShardItemId#5661070L, version#5661071, qty#5661072, demandChannel#5661073, demandStream#5661074, kpis#5661075])\n +- Exchange hashpartitioning(demandChannel#5661073, shardId#5661069, kpis#5661075, version#5661071, qty#5661072, worklistShardItemId#5661070L, demandStream#5661074, 30), ENSURE_REQUIREMENTS, [plan_id=2682531]\n +- HashAggregate(keys=[demandChannel#5661073, shardId#5661069, knownfloatingpointnormalized(transform(kpis#5661075, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5745017)) null else named_struct(label, lambda arg#5745017.label, dateTime, lambda arg#5745017.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5745017.value)))), lambda ... [341105] [Cached] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 341106 [id="node_341106" labelType="html" label="MapPartitionsRDD [341106] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 341107 [id="node_341107" labelType="html" label="MapPartitionsRDD [341107] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 341108 [id="node_341108" labelType="html" label="MapPartitionsRDD [341108] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_877441 { id="cluster_877441"; isCluster="true"; label="WholeStageCodegen (1)"; 341109 [id="node_341109" labelType="html" label="MapPartitionsRDD [341109] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_877440 { id="cluster_877440"; isCluster="true"; label="Exchange"; 341110 [id="node_341110" labelType="html" label="MapPartitionsRDD [341110] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 341103->341104; 341104->341105; 341105->341106; 341106->341107; 341107->341108; 341108->341109; 341109->341110; }

341102,341103

341105

digraph G { id="graph_1297470"; subgraph graph_stage_1297470 { id="graph_stage_1297470"; isCluster="true"; label="Stage 1297470"; subgraph cluster_877440 { id="cluster_877440"; isCluster="true"; label="Exchange"; 341111 [id="node_341111" labelType="html" label="ShuffledRowRDD [341111] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_877437 { id="cluster_877437"; isCluster="true"; label="WholeStageCodegen (2)"; 341112 [id="node_341112" labelType="html" label="MapPartitionsRDD [341112] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_877453 { id="cluster_877453"; isCluster="true"; label="mapPartitionsInternal"; 341113 [id="node_341113" labelType="html" label="MapPartitionsRDD [341113] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 341111->341112; 341112->341113; }

341110,341111

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1297470	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 18 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/05/22 09:42:01	0.1 s	30/30	672.0 B
1297469	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 18 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/05/22 09:42:01	0.4 s	30/30	13.0 KiB	672.0 B
1297468	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 18 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/05/22 09:42:01	0.2 s	30/30	13.2 KiB	13.0 KiB
1297467	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 18 start at FileStorageAdapterImpl.java:567 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:567) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor622.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:332) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:284) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:246) 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/05/22 09:42:00	0.2 s	23/23		13.2 KiB

Page: