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

Status: SUCCEEDED
Submitted: 2026/05/22 09:07:11
Duration: 1 s
Associated SQL Query: 24469
Job Group: 10d36e12-5b96-4752-9e6b-ca062fdd8807
Completed Stages: 4

Enable zooming

digraph G { id="graph_1261582"; subgraph graph_stage_1261582 { id="graph_stage_1261582"; isCluster="true"; label="Stage 1261582"; 331728 [id="node_331728" labelType="html" label="SQLExecutionRDD [331728] start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_853348 { id="cluster_853348"; isCluster="true"; label="Scan parquet "; 331725 [id="node_331725" labelType="html" label="FileScanRDD [331725] start at FileStorageAdapterImpl.java:567}"]; 331726 [id="node_331726" labelType="html" label="MapPartitionsRDD [331726] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853345 { id="cluster_853345"; isCluster="true"; label="WholeStageCodegen (1)"; 331727 [id="node_331727" labelType="html" label="MapPartitionsRDD [331727] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853363 { id="cluster_853363"; isCluster="true"; label="WholeStageCodegen (1)"; 331729 [id="node_331729" labelType="html" label="MapPartitionsRDD [331729] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853362 { id="cluster_853362"; isCluster="true"; label="HashAggregate"; 331730 [id="node_331730" labelType="html" label="MapPartitionsRDD [331730] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853361 { id="cluster_853361"; isCluster="true"; label="Exchange"; 331731 [id="node_331731" labelType="html" label="MapPartitionsRDD [331731] start at FileStorageAdapterImpl.java:567}"]; } } 331725->331726; 331726->331727; 331727->331728; 331728->331729; 331729->331730; 331730->331731; }

digraph G { id="graph_1261583"; subgraph graph_stage_1261583 { id="graph_stage_1261583"; isCluster="true"; label="Stage 1261583"; subgraph cluster_853361 { id="cluster_853361"; isCluster="true"; label="Exchange"; 331732 [id="node_331732" labelType="html" label="ShuffledRowRDD [331732] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853358 { id="cluster_853358"; isCluster="true"; label="WholeStageCodegen (2)"; 331733 [id="node_331733" labelType="html" label="MapPartitionsRDD [331733] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853357 { id="cluster_853357"; isCluster="true"; label="Exchange"; 331734 [id="node_331734" labelType="html" label="MapPartitionsRDD [331734] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 331732->331733; 331733->331734; }

331731,331732

digraph G { id="graph_1261584"; subgraph graph_stage_1261584 { id="graph_stage_1261584"; isCluster="true"; label="Stage 1261584"; subgraph cluster_853357 { id="cluster_853357"; isCluster="true"; label="Exchange"; 331735 [id="node_331735" labelType="html" label="ShuffledRowRDD [331735] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853356 { id="cluster_853356"; isCluster="true"; label="InMemoryTableScan"; 331736 [id="node_331736" labelType="html" label="MapPartitionsRDD [331736] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 331737 [id="node_331737" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#5176552L, 30), REPARTITION_BY_NUM, [plan_id=2614599]\n+- *(2) HashAggregate(keys=[demandChannel#5176555, shardId#5176551, kpis#5176557, version#5176553, qty#5176554, worklistShardItemId#5176552L, demandStream#5176556], functions=[], output=[shardId#5176551, worklistShardItemId#5176552L, version#5176553, qty#5176554, demandChannel#5176555, demandStream#5176556, kpis#5176557])\n +- Exchange hashpartitioning(demandChannel#5176555, shardId#5176551, kpis#5176557, version#5176553, qty#5176554, worklistShardItemId#5176552L, demandStream#5176556, 30), ENSURE_REQUIREMENTS, [plan_id=2614595]\n +- HashAggregate(keys=[demandChannel#5176555, shardId#5176551, knownfloatingpointnormalized(transform(kpis#5176557, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5598007)) null else named_struct(label, lambda arg#5598007.label, dateTime, lambda arg#5598007.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5598007.value)))), lambda ... [331737] [Cached] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 331738 [id="node_331738" labelType="html" label="MapPartitionsRDD [331738] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 331739 [id="node_331739" labelType="html" label="MapPartitionsRDD [331739] [Unordered] start at FileStorageAdapterImpl.java:567}"]; 331740 [id="node_331740" labelType="html" label="MapPartitionsRDD [331740] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853353 { id="cluster_853353"; isCluster="true"; label="WholeStageCodegen (1)"; 331741 [id="node_331741" labelType="html" label="MapPartitionsRDD [331741] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853352 { id="cluster_853352"; isCluster="true"; label="Exchange"; 331742 [id="node_331742" labelType="html" label="MapPartitionsRDD [331742] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 331735->331736; 331736->331737; 331737->331738; 331738->331739; 331739->331740; 331740->331741; 331741->331742; }

331734,331735

331737

digraph G { id="graph_1261585"; subgraph graph_stage_1261585 { id="graph_stage_1261585"; isCluster="true"; label="Stage 1261585"; subgraph cluster_853352 { id="cluster_853352"; isCluster="true"; label="Exchange"; 331743 [id="node_331743" labelType="html" label="ShuffledRowRDD [331743] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853349 { id="cluster_853349"; isCluster="true"; label="WholeStageCodegen (2)"; 331744 [id="node_331744" labelType="html" label="MapPartitionsRDD [331744] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_853365 { id="cluster_853365"; isCluster="true"; label="mapPartitionsInternal"; 331745 [id="node_331745" labelType="html" label="MapPartitionsRDD [331745] [Unordered] start at FileStorageAdapterImpl.java:567}"]; } } 331743->331744; 331744->331745; }

331742,331743

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1261585	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 38 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:07:13	0.1 s	30/30	1920.0 B
1261584	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 38 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:07:12	0.5 s	30/30	59.2 KiB	1920.0 B
1261583	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 38 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:07:12	0.1 s	30/30	62.2 KiB	59.2 KiB
1261582	tenants-pool-169	stream-10000000244-1 id = f4ddbf18-85c1-4896-8727-ce8f46084bea runId = 10d36e12-5b96-4752-9e6b-ca062fdd8807 batch = 38 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:07:11	0.7 s	29/29		62.2 KiB

Page: