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

Status: SUCCEEDED
Submitted: 2026/08/31 14:22:05
Duration: 6 s
Associated SQL Query: 13520
Job Group: 21238029-8f83-4dda-9603-e1612427f49b
Completed Stages: 4

Enable zooming

digraph G { id="graph_341142"; subgraph graph_stage_341142 { id="graph_stage_341142"; isCluster="true"; label="Stage 341142"; 154103 [id="node_154103" labelType="html" label="SQLExecutionRDD [154103] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_385411 { id="cluster_385411"; isCluster="true"; label="Scan parquet "; 154100 [id="node_154100" labelType="html" label="FileScanRDD [154100] start at FileStorageAdapterImpl.java:596}"]; 154101 [id="node_154101" labelType="html" label="MapPartitionsRDD [154101] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385408 { id="cluster_385408"; isCluster="true"; label="WholeStageCodegen (1)"; 154102 [id="node_154102" labelType="html" label="MapPartitionsRDD [154102] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385426 { id="cluster_385426"; isCluster="true"; label="WholeStageCodegen (1)"; 154104 [id="node_154104" labelType="html" label="MapPartitionsRDD [154104] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385425 { id="cluster_385425"; isCluster="true"; label="HashAggregate"; 154105 [id="node_154105" labelType="html" label="MapPartitionsRDD [154105] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385424 { id="cluster_385424"; isCluster="true"; label="Exchange"; 154106 [id="node_154106" labelType="html" label="MapPartitionsRDD [154106] start at FileStorageAdapterImpl.java:596}"]; } } 154100->154101; 154101->154102; 154102->154103; 154103->154104; 154104->154105; 154105->154106; }

digraph G { id="graph_341143"; subgraph graph_stage_341143 { id="graph_stage_341143"; isCluster="true"; label="Stage 341143"; subgraph cluster_385424 { id="cluster_385424"; isCluster="true"; label="Exchange"; 154107 [id="node_154107" labelType="html" label="ShuffledRowRDD [154107] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385421 { id="cluster_385421"; isCluster="true"; label="WholeStageCodegen (2)"; 154108 [id="node_154108" labelType="html" label="MapPartitionsRDD [154108] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385420 { id="cluster_385420"; isCluster="true"; label="Exchange"; 154109 [id="node_154109" labelType="html" label="MapPartitionsRDD [154109] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154107->154108; 154108->154109; }

154106,154107

digraph G { id="graph_341144"; subgraph graph_stage_341144 { id="graph_stage_341144"; isCluster="true"; label="Stage 341144"; subgraph cluster_385420 { id="cluster_385420"; isCluster="true"; label="Exchange"; 154110 [id="node_154110" labelType="html" label="ShuffledRowRDD [154110] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385419 { id="cluster_385419"; isCluster="true"; label="InMemoryTableScan"; 154111 [id="node_154111" labelType="html" label="MapPartitionsRDD [154111] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154112 [id="node_154112" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3615107L, 30), REPARTITION_BY_NUM, [plan_id=1034785]\n+- *(2) HashAggregate(keys=[demandChannel#3615110, shardId#3615106, kpis#3615112, version#3615108, qty#3615109, worklistShardItemId#3615107L, demandStream#3615111], functions=[], output=[shardId#3615106, worklistShardItemId#3615107L, version#3615108, qty#3615109, demandChannel#3615110, demandStream#3615111, kpis#3615112])\n +- Exchange hashpartitioning(demandChannel#3615110, shardId#3615106, kpis#3615112, version#3615108, qty#3615109, worklistShardItemId#3615107L, demandStream#3615111, 30), ENSURE_REQUIREMENTS, [plan_id=1034781]\n +- HashAggregate(keys=[demandChannel#3615110, shardId#3615106, knownfloatingpointnormalized(transform(kpis#3615112, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3615199)) null else named_struct(label, lambda arg#3615199.label, dateTime, lambda arg#3615199.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3615199.value)))), lambda ... [154112] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154113 [id="node_154113" labelType="html" label="MapPartitionsRDD [154113] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154114 [id="node_154114" labelType="html" label="MapPartitionsRDD [154114] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154115 [id="node_154115" labelType="html" label="MapPartitionsRDD [154115] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385416 { id="cluster_385416"; isCluster="true"; label="WholeStageCodegen (1)"; 154116 [id="node_154116" labelType="html" label="MapPartitionsRDD [154116] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385415 { id="cluster_385415"; isCluster="true"; label="Exchange"; 154117 [id="node_154117" labelType="html" label="MapPartitionsRDD [154117] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154110->154111; 154111->154112; 154112->154113; 154113->154114; 154114->154115; 154115->154116; 154116->154117; }

154109,154110

154112

digraph G { id="graph_341145"; subgraph graph_stage_341145 { id="graph_stage_341145"; isCluster="true"; label="Stage 341145"; subgraph cluster_385415 { id="cluster_385415"; isCluster="true"; label="Exchange"; 154118 [id="node_154118" labelType="html" label="ShuffledRowRDD [154118] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385412 { id="cluster_385412"; isCluster="true"; label="WholeStageCodegen (2)"; 154119 [id="node_154119" labelType="html" label="MapPartitionsRDD [154119] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385428 { id="cluster_385428"; isCluster="true"; label="mapPartitionsInternal"; 154120 [id="node_154120" labelType="html" label="MapPartitionsRDD [154120] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154118->154119; 154119->154120; }

154117,154118

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
341145	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 21238029-8f83-4dda-9603-e1612427f49b batch = 21 start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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/31 14:22:10	0.1 s	30/30	2.8 KiB
341144	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 21238029-8f83-4dda-9603-e1612427f49b batch = 21 start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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/31 14:22:08	2 s	30/30	12.0 MiB	2.8 KiB
341143	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 21238029-8f83-4dda-9603-e1612427f49b batch = 21 start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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/31 14:22:07	1 s	30/30	11.9 MiB	12.0 MiB
341142	tenants-pool-506	stream-10000000532-3 id = 6ef938e2-894b-409c-acaa-b6be27eb2f45 runId = 21238029-8f83-4dda-9603-e1612427f49b batch = 21 start at FileStorageAdapterImpl.java:596 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.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/31 14:22:05	2 s	30/30		11.9 MiB

Page: