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

Status: SUCCEEDED
Submitted: 2026/07/21 20:56:55
Duration: 0.3 s
Associated SQL Query: 34670
Job Group: 881110fc-a22e-43dd-9ef6-858dd65243b7
Completed Stages: 4

Enable zooming

digraph G { id="graph_1334381"; subgraph graph_stage_1334381 { id="graph_stage_1334381"; isCluster="true"; label="Stage 1334381"; 393288 [id="node_393288" labelType="html" label="SQLExecutionRDD [393288] start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_1035820 { id="cluster_1035820"; isCluster="true"; label="Scan parquet "; 393285 [id="node_393285" labelType="html" label="FileScanRDD [393285] start at FileStorageAdapterImpl.java:598}"]; 393286 [id="node_393286" labelType="html" label="MapPartitionsRDD [393286] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035817 { id="cluster_1035817"; isCluster="true"; label="WholeStageCodegen (1)"; 393287 [id="node_393287" labelType="html" label="MapPartitionsRDD [393287] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035835 { id="cluster_1035835"; isCluster="true"; label="WholeStageCodegen (1)"; 393289 [id="node_393289" labelType="html" label="MapPartitionsRDD [393289] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035834 { id="cluster_1035834"; isCluster="true"; label="HashAggregate"; 393290 [id="node_393290" labelType="html" label="MapPartitionsRDD [393290] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035833 { id="cluster_1035833"; isCluster="true"; label="Exchange"; 393291 [id="node_393291" labelType="html" label="MapPartitionsRDD [393291] start at FileStorageAdapterImpl.java:598}"]; } } 393285->393286; 393286->393287; 393287->393288; 393288->393289; 393289->393290; 393290->393291; }

digraph G { id="graph_1334382"; subgraph graph_stage_1334382 { id="graph_stage_1334382"; isCluster="true"; label="Stage 1334382"; subgraph cluster_1035833 { id="cluster_1035833"; isCluster="true"; label="Exchange"; 393292 [id="node_393292" labelType="html" label="ShuffledRowRDD [393292] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035830 { id="cluster_1035830"; isCluster="true"; label="WholeStageCodegen (2)"; 393293 [id="node_393293" labelType="html" label="MapPartitionsRDD [393293] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035829 { id="cluster_1035829"; isCluster="true"; label="Exchange"; 393294 [id="node_393294" labelType="html" label="MapPartitionsRDD [393294] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 393292->393293; 393293->393294; }

393291,393292

digraph G { id="graph_1334383"; subgraph graph_stage_1334383 { id="graph_stage_1334383"; isCluster="true"; label="Stage 1334383"; subgraph cluster_1035829 { id="cluster_1035829"; isCluster="true"; label="Exchange"; 393295 [id="node_393295" labelType="html" label="ShuffledRowRDD [393295] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035828 { id="cluster_1035828"; isCluster="true"; label="InMemoryTableScan"; 393296 [id="node_393296" labelType="html" label="MapPartitionsRDD [393296] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 393297 [id="node_393297" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#4883822L, 30), REPARTITION_BY_NUM, [plan_id=2893268]\n+- *(2) HashAggregate(keys=[demandChannel#4883825, shardId#4883821, kpis#4883827, version#4883823, qty#4883824, worklistShardItemId#4883822L, demandStream#4883826], functions=[], output=[shardId#4883821, worklistShardItemId#4883822L, version#4883823, qty#4883824, demandChannel#4883825, demandStream#4883826, kpis#4883827])\n +- Exchange hashpartitioning(demandChannel#4883825, shardId#4883821, kpis#4883827, version#4883823, qty#4883824, worklistShardItemId#4883822L, demandStream#4883826, 30), ENSURE_REQUIREMENTS, [plan_id=2893264]\n +- HashAggregate(keys=[demandChannel#4883825, shardId#4883821, knownfloatingpointnormalized(transform(kpis#4883827, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5580251)) null else named_struct(label, lambda arg#5580251.label, dateTime, lambda arg#5580251.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5580251.value)))), lambda ... [393297] [Cached] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 393298 [id="node_393298" labelType="html" label="MapPartitionsRDD [393298] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 393299 [id="node_393299" labelType="html" label="MapPartitionsRDD [393299] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 393300 [id="node_393300" labelType="html" label="MapPartitionsRDD [393300] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035825 { id="cluster_1035825"; isCluster="true"; label="WholeStageCodegen (1)"; 393301 [id="node_393301" labelType="html" label="MapPartitionsRDD [393301] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035824 { id="cluster_1035824"; isCluster="true"; label="Exchange"; 393302 [id="node_393302" labelType="html" label="MapPartitionsRDD [393302] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 393295->393296; 393296->393297; 393297->393298; 393298->393299; 393299->393300; 393300->393301; 393301->393302; }

393294,393295

393297

digraph G { id="graph_1334384"; subgraph graph_stage_1334384 { id="graph_stage_1334384"; isCluster="true"; label="Stage 1334384"; subgraph cluster_1035824 { id="cluster_1035824"; isCluster="true"; label="Exchange"; 393303 [id="node_393303" labelType="html" label="ShuffledRowRDD [393303] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035821 { id="cluster_1035821"; isCluster="true"; label="WholeStageCodegen (2)"; 393304 [id="node_393304" labelType="html" label="MapPartitionsRDD [393304] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035837 { id="cluster_1035837"; isCluster="true"; label="mapPartitionsInternal"; 393305 [id="node_393305" labelType="html" label="MapPartitionsRDD [393305] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 393303->393304; 393304->393305; }

393302,393303

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1334384	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 97 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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/07/21 20:56:56	31 ms	30/30	480.0 B
1334383	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 97 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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/07/21 20:56:55	61 ms	30/30	9.6 KiB	480.0 B
1334382	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 97 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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/07/21 20:56:55	52 ms	30/30	9.4 KiB	9.6 KiB
1334381	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 97 start at FileStorageAdapterImpl.java:598 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:598) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor658.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/07/21 20:56:55	0.2 s	13/13		9.4 KiB

Page: