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

Status: SUCCEEDED
Submitted: 2026/07/21 20:57:22
Duration: 0.4 s
Associated SQL Query: 34693
Job Group: 881110fc-a22e-43dd-9ef6-858dd65243b7
Completed Stages: 4

Enable zooming

digraph G { id="graph_1335544"; subgraph graph_stage_1335544 { id="graph_stage_1335544"; isCluster="true"; label="Stage 1335544"; 393548 [id="node_393548" labelType="html" label="SQLExecutionRDD [393548] start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_1036516 { id="cluster_1036516"; isCluster="true"; label="Scan parquet "; 393545 [id="node_393545" labelType="html" label="FileScanRDD [393545] start at FileStorageAdapterImpl.java:598}"]; 393546 [id="node_393546" labelType="html" label="MapPartitionsRDD [393546] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1036513 { id="cluster_1036513"; isCluster="true"; label="WholeStageCodegen (1)"; 393547 [id="node_393547" labelType="html" label="MapPartitionsRDD [393547] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1036531 { id="cluster_1036531"; isCluster="true"; label="WholeStageCodegen (1)"; 393549 [id="node_393549" labelType="html" label="MapPartitionsRDD [393549] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1036530 { id="cluster_1036530"; isCluster="true"; label="HashAggregate"; 393550 [id="node_393550" labelType="html" label="MapPartitionsRDD [393550] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1036529 { id="cluster_1036529"; isCluster="true"; label="Exchange"; 393551 [id="node_393551" labelType="html" label="MapPartitionsRDD [393551] start at FileStorageAdapterImpl.java:598}"]; } } 393545->393546; 393546->393547; 393547->393548; 393548->393549; 393549->393550; 393550->393551; }

digraph G { id="graph_1335545"; subgraph graph_stage_1335545 { id="graph_stage_1335545"; isCluster="true"; label="Stage 1335545"; subgraph cluster_1036529 { id="cluster_1036529"; isCluster="true"; label="Exchange"; 393552 [id="node_393552" labelType="html" label="ShuffledRowRDD [393552] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1036526 { id="cluster_1036526"; isCluster="true"; label="WholeStageCodegen (2)"; 393553 [id="node_393553" labelType="html" label="MapPartitionsRDD [393553] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1036525 { id="cluster_1036525"; isCluster="true"; label="Exchange"; 393554 [id="node_393554" labelType="html" label="MapPartitionsRDD [393554] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 393552->393553; 393553->393554; }

393551,393552

digraph G { id="graph_1335546"; subgraph graph_stage_1335546 { id="graph_stage_1335546"; isCluster="true"; label="Stage 1335546"; subgraph cluster_1036525 { id="cluster_1036525"; isCluster="true"; label="Exchange"; 393555 [id="node_393555" labelType="html" label="ShuffledRowRDD [393555] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1036524 { id="cluster_1036524"; isCluster="true"; label="InMemoryTableScan"; 393556 [id="node_393556" labelType="html" label="MapPartitionsRDD [393556] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 393557 [id="node_393557" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#4883822L, 30), REPARTITION_BY_NUM, [plan_id=2895049]\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=2895045]\n +- HashAggregate(keys=[demandChannel#4883825, shardId#4883821, knownfloatingpointnormalized(transform(kpis#4883827, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5582627)) null else named_struct(label, lambda arg#5582627.label, dateTime, lambda arg#5582627.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5582627.value)))), lambda ... [393557] [Cached] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 393558 [id="node_393558" labelType="html" label="MapPartitionsRDD [393558] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 393559 [id="node_393559" labelType="html" label="MapPartitionsRDD [393559] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 393560 [id="node_393560" labelType="html" label="MapPartitionsRDD [393560] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1036521 { id="cluster_1036521"; isCluster="true"; label="WholeStageCodegen (1)"; 393561 [id="node_393561" labelType="html" label="MapPartitionsRDD [393561] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1036520 { id="cluster_1036520"; isCluster="true"; label="Exchange"; 393562 [id="node_393562" labelType="html" label="MapPartitionsRDD [393562] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 393555->393556; 393556->393557; 393557->393558; 393558->393559; 393559->393560; 393560->393561; 393561->393562; }

393554,393555

393557

digraph G { id="graph_1335547"; subgraph graph_stage_1335547 { id="graph_stage_1335547"; isCluster="true"; label="Stage 1335547"; subgraph cluster_1036520 { id="cluster_1036520"; isCluster="true"; label="Exchange"; 393563 [id="node_393563" labelType="html" label="ShuffledRowRDD [393563] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1036517 { id="cluster_1036517"; isCluster="true"; label="WholeStageCodegen (2)"; 393564 [id="node_393564" labelType="html" label="MapPartitionsRDD [393564] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1036533 { id="cluster_1036533"; isCluster="true"; label="mapPartitionsInternal"; 393565 [id="node_393565" labelType="html" label="MapPartitionsRDD [393565] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 393563->393564; 393564->393565; }

393562,393563

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1335547	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 98 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:57:22	17 ms	30/30	384.0 B
1335546	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 98 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:57:22	0.1 s	30/30	4.2 KiB	384.0 B
1335545	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 98 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:57:22	37 ms	30/30	4.7 KiB	4.2 KiB
1335544	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 98 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:57:22	0.2 s	7/7		4.7 KiB

Page: