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

Status: SUCCEEDED
Submitted: 2026/05/22 09:39:30
Duration: 1.0 s
Associated SQL Query: 25077
Job Group: 65cb8160-40af-4a1d-9ef7-845fbd048abf
Completed Stages: 4

Enable zooming

digraph G { id="graph_1286997"; subgraph graph_stage_1286997 { id="graph_stage_1286997"; isCluster="true"; label="Stage 1286997"; 339556 [id="node_339556" labelType="html" label="SQLExecutionRDD [339556] start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_873510 { id="cluster_873510"; isCluster="true"; label="Scan parquet "; 339553 [id="node_339553" labelType="html" label="FileScanRDD [339553] start at FileStorageAdapterImpl.java:567}"]; 339554 [id="node_339554" labelType="html" label="MapPartitionsRDD [339554] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_873507 { id="cluster_873507"; isCluster="true"; label="WholeStageCodegen (1)"; 339555 [id="node_339555" labelType="html" label="MapPartitionsRDD [339555] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_873525 { id="cluster_873525"; isCluster="true"; label="WholeStageCodegen (1)"; 339557 [id="node_339557" labelType="html" label="MapPartitionsRDD [339557] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_873524 { id="cluster_873524"; isCluster="true"; label="HashAggregate"; 339558 [id="node_339558" labelType="html" label="MapPartitionsRDD [339558] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_873523 { id="cluster_873523"; isCluster="true"; label="Exchange"; 339559 [id="node_339559" labelType="html" label="MapPartitionsRDD [339559] start at FileStorageAdapterImpl.java:567}"]; } } 339553->339554; 339554->339555; 339555->339556; 339556->339557; 339557->339558; 339558->339559; }

digraph G { id="graph_1286998"; subgraph graph_stage_1286998 { id="graph_stage_1286998"; isCluster="true"; label="Stage 1286998"; subgraph cluster_873523 { id="cluster_873523"; isCluster="true"; label="Exchange"; 339560 [id="node_339560" labelType="html" label="ShuffledRowRDD [339560] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_873520 { id="cluster_873520"; isCluster="true"; label="WholeStageCodegen (2)"; 339561 [id="node_339561" labelType="html" label="MapPartitionsRDD [339561] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_873519 { id="cluster_873519"; isCluster="true"; label="Exchange"; 339562 [id="node_339562" labelType="html" label="MapPartitionsRDD [339562] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 339560->339561; 339561->339562; }

339559,339560

digraph G { id="graph_1286999"; subgraph graph_stage_1286999 { id="graph_stage_1286999"; isCluster="true"; label="Stage 1286999"; subgraph cluster_873519 { id="cluster_873519"; isCluster="true"; label="Exchange"; 339563 [id="node_339563" labelType="html" label="ShuffledRowRDD [339563] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_873518 { id="cluster_873518"; isCluster="true"; label="InMemoryTableScan"; 339564 [id="node_339564" labelType="html" label="MapPartitionsRDD [339564] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 339565 [id="node_339565" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#5661070L, 30), REPARTITION_BY_NUM, [plan_id=2672469]\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=2672465]\n +- HashAggregate(keys=[demandChannel#5661073, shardId#5661069, knownfloatingpointnormalized(transform(kpis#5661075, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5720173)) null else named_struct(label, lambda arg#5720173.label, dateTime, lambda arg#5720173.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5720173.value)))), lambda ... [339565] [Cached] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 339566 [id="node_339566" labelType="html" label="MapPartitionsRDD [339566] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 339567 [id="node_339567" labelType="html" label="MapPartitionsRDD [339567] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 339568 [id="node_339568" labelType="html" label="MapPartitionsRDD [339568] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_873515 { id="cluster_873515"; isCluster="true"; label="WholeStageCodegen (1)"; 339569 [id="node_339569" labelType="html" label="MapPartitionsRDD [339569] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_873514 { id="cluster_873514"; isCluster="true"; label="Exchange"; 339570 [id="node_339570" labelType="html" label="MapPartitionsRDD [339570] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 339563->339564; 339564->339565; 339565->339566; 339566->339567; 339567->339568; 339568->339569; 339569->339570; }

339562,339563

339565

digraph G { id="graph_1287000"; subgraph graph_stage_1287000 { id="graph_stage_1287000"; isCluster="true"; label="Stage 1287000"; subgraph cluster_873514 { id="cluster_873514"; isCluster="true"; label="Exchange"; 339571 [id="node_339571" labelType="html" label="ShuffledRowRDD [339571] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_873511 { id="cluster_873511"; isCluster="true"; label="WholeStageCodegen (2)"; 339572 [id="node_339572" labelType="html" label="MapPartitionsRDD [339572] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_873527 { id="cluster_873527"; isCluster="true"; label="mapPartitionsInternal"; 339573 [id="node_339573" labelType="html" label="MapPartitionsRDD [339573] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 339571->339572; 339572->339573; }

339570,339571

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1287000	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 14 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:39:31	0.1 s	30/30	288.0 B
1286999	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 14 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:39:30	0.4 s	30/30	2.2 KiB	288.0 B
1286998	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 14 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:39:30	0.1 s	30/30	2.5 KiB	2.2 KiB
1286997	tenants-pool-169	stream-10000000246-1 id = 4aa13108-ed0f-4533-b11e-6fef3e770cf7 runId = 65cb8160-40af-4a1d-9ef7-845fbd048abf batch = 14 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:39:30	0.4 s	6/6		2.5 KiB

Page: