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

Status: SUCCEEDED
Submitted: 2026/07/22 20:36:55
Duration: 0.6 s
Associated SQL Query: 93768
Job Group: f82340b3-4413-4826-9fdb-37fdaa6940fe
Completed Stages: 4

Enable zooming

digraph G { id="graph_3725810"; subgraph graph_stage_3725810 { id="graph_stage_3725810"; isCluster="true"; label="Stage 3725810"; 1062040 [id="node_1062040" labelType="html" label="SQLExecutionRDD [1062040] start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_2796595 { id="cluster_2796595"; isCluster="true"; label="Scan parquet "; 1062037 [id="node_1062037" labelType="html" label="FileScanRDD [1062037] start at FileStorageAdapterImpl.java:598}"]; 1062038 [id="node_1062038" labelType="html" label="MapPartitionsRDD [1062038] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796592 { id="cluster_2796592"; isCluster="true"; label="WholeStageCodegen (1)"; 1062039 [id="node_1062039" labelType="html" label="MapPartitionsRDD [1062039] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796610 { id="cluster_2796610"; isCluster="true"; label="WholeStageCodegen (1)"; 1062041 [id="node_1062041" labelType="html" label="MapPartitionsRDD [1062041] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796609 { id="cluster_2796609"; isCluster="true"; label="HashAggregate"; 1062042 [id="node_1062042" labelType="html" label="MapPartitionsRDD [1062042] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796608 { id="cluster_2796608"; isCluster="true"; label="Exchange"; 1062043 [id="node_1062043" labelType="html" label="MapPartitionsRDD [1062043] start at FileStorageAdapterImpl.java:598}"]; } } 1062037->1062038; 1062038->1062039; 1062039->1062040; 1062040->1062041; 1062041->1062042; 1062042->1062043; }

digraph G { id="graph_3725811"; subgraph graph_stage_3725811 { id="graph_stage_3725811"; isCluster="true"; label="Stage 3725811"; subgraph cluster_2796608 { id="cluster_2796608"; isCluster="true"; label="Exchange"; 1062044 [id="node_1062044" labelType="html" label="ShuffledRowRDD [1062044] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796605 { id="cluster_2796605"; isCluster="true"; label="WholeStageCodegen (2)"; 1062045 [id="node_1062045" labelType="html" label="MapPartitionsRDD [1062045] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796604 { id="cluster_2796604"; isCluster="true"; label="Exchange"; 1062046 [id="node_1062046" labelType="html" label="MapPartitionsRDD [1062046] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 1062044->1062045; 1062045->1062046; }

1062043,1062044

digraph G { id="graph_3725812"; subgraph graph_stage_3725812 { id="graph_stage_3725812"; isCluster="true"; label="Stage 3725812"; subgraph cluster_2796604 { id="cluster_2796604"; isCluster="true"; label="Exchange"; 1062047 [id="node_1062047" labelType="html" label="ShuffledRowRDD [1062047] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796603 { id="cluster_2796603"; isCluster="true"; label="InMemoryTableScan"; 1062048 [id="node_1062048" labelType="html" label="MapPartitionsRDD [1062048] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 1062049 [id="node_1062049" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#14510171L, 30), REPARTITION_BY_NUM, [plan_id=7841967]\n+- *(2) HashAggregate(keys=[demandChannel#14510174, shardId#14510170, kpis#14510176, version#14510172, qty#14510173, worklistShardItemId#14510171L, demandStream#14510175], functions=[], output=[shardId#14510170, worklistShardItemId#14510171L, version#14510172, qty#14510173, demandChannel#14510174, demandStream#14510175, kpis#14510176])\n +- Exchange hashpartitioning(demandChannel#14510174, shardId#14510170, kpis#14510176, version#14510172, qty#14510173, worklistShardItemId#14510171L, demandStream#14510175, 30), ENSURE_REQUIREMENTS, [plan_id=7841963]\n +- HashAggregate(keys=[demandChannel#14510174, shardId#14510170, knownfloatingpointnormalized(transform(kpis#14510176, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#15069205)) null else named_struct(label, lambda arg#15069205.label, dateTime, lambda arg#15069205.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [1062049] [Cached] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 1062050 [id="node_1062050" labelType="html" label="MapPartitionsRDD [1062050] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 1062051 [id="node_1062051" labelType="html" label="MapPartitionsRDD [1062051] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 1062052 [id="node_1062052" labelType="html" label="MapPartitionsRDD [1062052] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796600 { id="cluster_2796600"; isCluster="true"; label="WholeStageCodegen (1)"; 1062053 [id="node_1062053" labelType="html" label="MapPartitionsRDD [1062053] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796599 { id="cluster_2796599"; isCluster="true"; label="Exchange"; 1062054 [id="node_1062054" labelType="html" label="MapPartitionsRDD [1062054] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 1062047->1062048; 1062048->1062049; 1062049->1062050; 1062050->1062051; 1062051->1062052; 1062052->1062053; 1062053->1062054; }

1062046,1062047

1062049

digraph G { id="graph_3725813"; subgraph graph_stage_3725813 { id="graph_stage_3725813"; isCluster="true"; label="Stage 3725813"; subgraph cluster_2796599 { id="cluster_2796599"; isCluster="true"; label="Exchange"; 1062055 [id="node_1062055" labelType="html" label="ShuffledRowRDD [1062055] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796596 { id="cluster_2796596"; isCluster="true"; label="WholeStageCodegen (2)"; 1062056 [id="node_1062056" labelType="html" label="MapPartitionsRDD [1062056] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796612 { id="cluster_2796612"; isCluster="true"; label="mapPartitionsInternal"; 1062057 [id="node_1062057" labelType="html" label="MapPartitionsRDD [1062057] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 1062055->1062056; 1062056->1062057; }

1062054,1062055

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
3725813	tenants-pool-169	stream-10000001452-1 id = d8095b92-94ab-46e0-9c45-70c2545e39e1 runId = f82340b3-4413-4826-9fdb-37fdaa6940fe batch = 69 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/22 20:36:56	0.1 s	30/30	96.0 B
3725812	tenants-pool-169	stream-10000001452-1 id = d8095b92-94ab-46e0-9c45-70c2545e39e1 runId = f82340b3-4413-4826-9fdb-37fdaa6940fe batch = 69 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/22 20:36:55	0.1 s	30/30	2.4 KiB	96.0 B
3725811	tenants-pool-169	stream-10000001452-1 id = d8095b92-94ab-46e0-9c45-70c2545e39e1 runId = f82340b3-4413-4826-9fdb-37fdaa6940fe batch = 69 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/22 20:36:55	0.1 s	30/30	2.3 KiB	2.4 KiB
3725810	tenants-pool-169	stream-10000001452-1 id = d8095b92-94ab-46e0-9c45-70c2545e39e1 runId = f82340b3-4413-4826-9fdb-37fdaa6940fe batch = 69 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/22 20:36:55	0.2 s	4/4		2.3 KiB

Page: