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

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

Enable zooming

digraph G { id="graph_1333354"; subgraph graph_stage_1333354 { id="graph_stage_1333354"; isCluster="true"; label="Stage 1333354"; 393028 [id="node_393028" labelType="html" label="SQLExecutionRDD [393028] start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_1035124 { id="cluster_1035124"; isCluster="true"; label="Scan parquet "; 393025 [id="node_393025" labelType="html" label="FileScanRDD [393025] start at FileStorageAdapterImpl.java:598}"]; 393026 [id="node_393026" labelType="html" label="MapPartitionsRDD [393026] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035121 { id="cluster_1035121"; isCluster="true"; label="WholeStageCodegen (1)"; 393027 [id="node_393027" labelType="html" label="MapPartitionsRDD [393027] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035139 { id="cluster_1035139"; isCluster="true"; label="WholeStageCodegen (1)"; 393029 [id="node_393029" labelType="html" label="MapPartitionsRDD [393029] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035138 { id="cluster_1035138"; isCluster="true"; label="HashAggregate"; 393030 [id="node_393030" labelType="html" label="MapPartitionsRDD [393030] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035137 { id="cluster_1035137"; isCluster="true"; label="Exchange"; 393031 [id="node_393031" labelType="html" label="MapPartitionsRDD [393031] start at FileStorageAdapterImpl.java:598}"]; } } 393025->393026; 393026->393027; 393027->393028; 393028->393029; 393029->393030; 393030->393031; }

digraph G { id="graph_1333355"; subgraph graph_stage_1333355 { id="graph_stage_1333355"; isCluster="true"; label="Stage 1333355"; subgraph cluster_1035137 { id="cluster_1035137"; isCluster="true"; label="Exchange"; 393032 [id="node_393032" labelType="html" label="ShuffledRowRDD [393032] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035134 { id="cluster_1035134"; isCluster="true"; label="WholeStageCodegen (2)"; 393033 [id="node_393033" labelType="html" label="MapPartitionsRDD [393033] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035133 { id="cluster_1035133"; isCluster="true"; label="Exchange"; 393034 [id="node_393034" labelType="html" label="MapPartitionsRDD [393034] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 393032->393033; 393033->393034; }

393031,393032

digraph G { id="graph_1333356"; subgraph graph_stage_1333356 { id="graph_stage_1333356"; isCluster="true"; label="Stage 1333356"; subgraph cluster_1035133 { id="cluster_1035133"; isCluster="true"; label="Exchange"; 393035 [id="node_393035" labelType="html" label="ShuffledRowRDD [393035] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035132 { id="cluster_1035132"; isCluster="true"; label="InMemoryTableScan"; 393036 [id="node_393036" labelType="html" label="MapPartitionsRDD [393036] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 393037 [id="node_393037" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#4883822L, 30), REPARTITION_BY_NUM, [plan_id=2891487]\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=2891483]\n +- HashAggregate(keys=[demandChannel#4883825, shardId#4883821, knownfloatingpointnormalized(transform(kpis#4883827, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#5577875)) null else named_struct(label, lambda arg#5577875.label, dateTime, lambda arg#5577875.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#5577875.value)))), lambda ... [393037] [Cached] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 393038 [id="node_393038" labelType="html" label="MapPartitionsRDD [393038] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 393039 [id="node_393039" labelType="html" label="MapPartitionsRDD [393039] [Unordered] start at FileStorageAdapterImpl.java:598}"]; 393040 [id="node_393040" labelType="html" label="MapPartitionsRDD [393040] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035129 { id="cluster_1035129"; isCluster="true"; label="WholeStageCodegen (1)"; 393041 [id="node_393041" labelType="html" label="MapPartitionsRDD [393041] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035128 { id="cluster_1035128"; isCluster="true"; label="Exchange"; 393042 [id="node_393042" labelType="html" label="MapPartitionsRDD [393042] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 393035->393036; 393036->393037; 393037->393038; 393038->393039; 393039->393040; 393040->393041; 393041->393042; }

393034,393035

393037

digraph G { id="graph_1333357"; subgraph graph_stage_1333357 { id="graph_stage_1333357"; isCluster="true"; label="Stage 1333357"; subgraph cluster_1035128 { id="cluster_1035128"; isCluster="true"; label="Exchange"; 393043 [id="node_393043" labelType="html" label="ShuffledRowRDD [393043] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035125 { id="cluster_1035125"; isCluster="true"; label="WholeStageCodegen (2)"; 393044 [id="node_393044" labelType="html" label="MapPartitionsRDD [393044] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1035141 { id="cluster_1035141"; isCluster="true"; label="mapPartitionsInternal"; 393045 [id="node_393045" labelType="html" label="MapPartitionsRDD [393045] [Unordered] start at FileStorageAdapterImpl.java:598}"]; } } 393043->393044; 393044->393045; }

393042,393043

Completed Stages (4)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Shuffle Read	Shuffle Write
1333357	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 96 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:26	16 ms	30/30	480.0 B
1333356	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 96 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:26	0.1 s	30/30	10.7 KiB	480.0 B
1333355	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 96 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:26	41 ms	30/30	10.5 KiB	10.7 KiB
1333354	tenants-pool-169	stream-10000001445-1 id = 26c9c63a-530b-4359-9e14-1592a674aa0e runId = 881110fc-a22e-43dd-9ef6-858dd65243b7 batch = 96 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:25	0.3 s	13/13		10.5 KiB

Page: