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

Status: SUCCEEDED
Submitted: 2026/08/31 14:22:21
Duration: 17 s
Associated SQL Query: 13518
Job Group: 21238029-8f83-4dda-9603-e1612427f49b
Completed Stages: 3
Skipped Stages: 9

Enable zooming

digraph G { id="graph_341154"; subgraph graph_stage_341154 { id="graph_stage_341154"; isCluster="true"; label="Stage 341154 (skipped)"; 153792 [id="node_153792" labelType="html" label="SQLExecutionRDD [153792] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_381879 { id="cluster_381879"; isCluster="true"; label="map"; 152695 [id="node_152695" labelType="html" label="MapPartitionsRDD [152695] [Cached] [Indeterminate] map at PeriodicAsyncRDDCheckpointWriterImpl.java:207}"]; } subgraph cluster_381900 { id="cluster_381900"; isCluster="true"; label="checkpoint"; 152698 [id="node_152698" labelType="html" label="LocalCheckpointRDD [152698] count at KpiCurveCacheImpl.java:255}"]; } subgraph cluster_384774 { id="cluster_384774"; isCluster="true"; label="map"; 153789 [id="node_153789" labelType="html" label="MapPartitionsRDD [153789] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384776 { id="cluster_384776"; isCluster="true"; label="WholeStageCodegen (1)"; 153790 [id="node_153790" labelType="html" label="MapPartitionsRDD [153790] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384775 { id="cluster_384775"; isCluster="true"; label="DeserializeToObject"; 153791 [id="node_153791" labelType="html" label="MapPartitionsRDD [153791] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384779 { id="cluster_384779"; isCluster="true"; label="mapPartitions"; 153793 [id="node_153793" labelType="html" label="MapPartitionsRDD [153793] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384780 { id="cluster_384780"; isCluster="true"; label="repartition"; 153794 [id="node_153794" labelType="html" label="MapPartitionsRDD [153794] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 152698->152695; 152695->153789; 153789->153790; 153790->153791; 153791->153792; 153792->153793; 153793->153794; }

152695

153792

152695

153789

153790

153791

153793

153794

digraph G { id="graph_341155"; subgraph graph_stage_341155 { id="graph_stage_341155"; isCluster="true"; label="Stage 341155 (skipped)"; 153802 [id="node_153802" labelType="html" label="SQLExecutionRDD [153802] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_384780 { id="cluster_384780"; isCluster="true"; label="repartition"; 153795 [id="node_153795" labelType="html" label="ShuffledRDD [153795] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153796 [id="node_153796" labelType="html" label="CoalescedRDD [153796] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153797 [id="node_153797" labelType="html" label="MapPartitionsRDD [153797] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384805 { id="cluster_384805"; isCluster="true"; label="map"; 153798 [id="node_153798" labelType="html" label="MapPartitionsRDD [153798] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384808 { id="cluster_384808"; isCluster="true"; label="WholeStageCodegen (1)"; 153800 [id="node_153800" labelType="html" label="MapPartitionsRDD [153800] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384807 { id="cluster_384807"; isCluster="true"; label="DeserializeToObject"; 153801 [id="node_153801" labelType="html" label="MapPartitionsRDD [153801] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384815 { id="cluster_384815"; isCluster="true"; label="mapPartitions"; 153803 [id="node_153803" labelType="html" label="MapPartitionsRDD [153803] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384816 { id="cluster_384816"; isCluster="true"; label="repartition"; 153804 [id="node_153804" labelType="html" label="MapPartitionsRDD [153804] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 153795->153796; 153796->153797; 153797->153798; 153798->153800; 153800->153801; 153801->153802; 153802->153803; 153803->153804; }

153794,153795

153797

153802

153795

153796

153797

153798

153800

153801

153803

153804

digraph G { id="graph_341156"; subgraph graph_stage_341156 { id="graph_stage_341156"; isCluster="true"; label="Stage 341156 (skipped)"; 154061 [id="node_154061" labelType="html" label="SQLExecutionRDD [154061] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_385367 { id="cluster_385367"; isCluster="true"; label="Scan parquet "; 154058 [id="node_154058" labelType="html" label="FileScanRDD [154058] start at FileStorageAdapterImpl.java:596}"]; 154059 [id="node_154059" labelType="html" label="MapPartitionsRDD [154059] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385364 { id="cluster_385364"; isCluster="true"; label="WholeStageCodegen (1)"; 154060 [id="node_154060" labelType="html" label="MapPartitionsRDD [154060] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385382 { id="cluster_385382"; isCluster="true"; label="WholeStageCodegen (1)"; 154062 [id="node_154062" labelType="html" label="MapPartitionsRDD [154062] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385381 { id="cluster_385381"; isCluster="true"; label="HashAggregate"; 154063 [id="node_154063" labelType="html" label="MapPartitionsRDD [154063] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385380 { id="cluster_385380"; isCluster="true"; label="Exchange"; 154064 [id="node_154064" labelType="html" label="MapPartitionsRDD [154064] start at FileStorageAdapterImpl.java:596}"]; } } 154058->154059; 154059->154060; 154060->154061; 154061->154062; 154062->154063; 154063->154064; }

digraph G { id="graph_341157"; subgraph graph_stage_341157 { id="graph_stage_341157"; isCluster="true"; label="Stage 341157 (skipped)"; subgraph cluster_385380 { id="cluster_385380"; isCluster="true"; label="Exchange"; 154065 [id="node_154065" labelType="html" label="ShuffledRowRDD [154065] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385377 { id="cluster_385377"; isCluster="true"; label="WholeStageCodegen (2)"; 154066 [id="node_154066" labelType="html" label="MapPartitionsRDD [154066] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385376 { id="cluster_385376"; isCluster="true"; label="Exchange"; 154067 [id="node_154067" labelType="html" label="MapPartitionsRDD [154067] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154065->154066; 154066->154067; }

154064,154065

digraph G { id="graph_341158"; subgraph graph_stage_341158 { id="graph_stage_341158"; isCluster="true"; label="Stage 341158 (skipped)"; 153983 [id="node_153983" labelType="html" label="SQLExecutionRDD [153983] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_384816 { id="cluster_384816"; isCluster="true"; label="repartition"; 153805 [id="node_153805" labelType="html" label="ShuffledRDD [153805] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153806 [id="node_153806" labelType="html" label="CoalescedRDD [153806] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153807 [id="node_153807" labelType="html" label="MapPartitionsRDD [153807] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385197 { id="cluster_385197"; isCluster="true"; label="map"; 153980 [id="node_153980" labelType="html" label="MapPartitionsRDD [153980] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385199 { id="cluster_385199"; isCluster="true"; label="WholeStageCodegen (1)"; 153981 [id="node_153981" labelType="html" label="MapPartitionsRDD [153981] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385198 { id="cluster_385198"; isCluster="true"; label="DeserializeToObject"; 153982 [id="node_153982" labelType="html" label="MapPartitionsRDD [153982] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385202 { id="cluster_385202"; isCluster="true"; label="mapPartitions"; 153984 [id="node_153984" labelType="html" label="MapPartitionsRDD [153984] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385203 { id="cluster_385203"; isCluster="true"; label="repartition"; 153985 [id="node_153985" labelType="html" label="MapPartitionsRDD [153985] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 153805->153806; 153806->153807; 153807->153980; 153980->153981; 153981->153982; 153982->153983; 153983->153984; 153984->153985; }

153804,153805

153807

153983

153805

153806

153807

153980

153981

153982

153984

153985

digraph G { id="graph_341159"; subgraph graph_stage_341159 { id="graph_stage_341159"; isCluster="true"; label="Stage 341159 (skipped)"; 154125 [id="node_154125" labelType="html" label="SQLExecutionRDD [154125] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_385203 { id="cluster_385203"; isCluster="true"; label="repartition"; 153986 [id="node_153986" labelType="html" label="ShuffledRDD [153986] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153987 [id="node_153987" labelType="html" label="CoalescedRDD [153987] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 153988 [id="node_153988" labelType="html" label="MapPartitionsRDD [153988] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385376 { id="cluster_385376"; isCluster="true"; label="Exchange"; 154068 [id="node_154068" labelType="html" label="ShuffledRowRDD [154068] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385375 { id="cluster_385375"; isCluster="true"; label="InMemoryTableScan"; 154069 [id="node_154069" labelType="html" label="MapPartitionsRDD [154069] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154070 [id="node_154070" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3614482L, 30), REPARTITION_BY_NUM, [plan_id=1034625]\n+- *(2) HashAggregate(keys=[demandChannel#3614485, shardId#3614481, kpis#3614487, version#3614483, qty#3614484, worklistShardItemId#3614482L, demandStream#3614486], functions=[], output=[shardId#3614481, worklistShardItemId#3614482L, version#3614483, qty#3614484, demandChannel#3614485, demandStream#3614486, kpis#3614487])\n +- Exchange hashpartitioning(demandChannel#3614485, shardId#3614481, kpis#3614487, version#3614483, qty#3614484, worklistShardItemId#3614482L, demandStream#3614486, 30), ENSURE_REQUIREMENTS, [plan_id=1034621]\n +- HashAggregate(keys=[demandChannel#3614485, shardId#3614481, knownfloatingpointnormalized(transform(kpis#3614487, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3614581)) null else named_struct(label, lambda arg#3614581.label, dateTime, lambda arg#3614581.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3614581.value)))), lambda ... [154070] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385452 { id="cluster_385452"; isCluster="true"; label="InMemoryTableScan"; 154121 [id="node_154121" labelType="html" label="MapPartitionsRDD [154121] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154122 [id="node_154122" labelType="html" label="MapPartitionsRDD [154122] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154123 [id="node_154123" labelType="html" label="MapPartitionsRDD [154123] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385451 { id="cluster_385451"; isCluster="true"; label="DeserializeToObject"; 154124 [id="node_154124" labelType="html" label="MapPartitionsRDD [154124] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385453 { id="cluster_385453"; isCluster="true"; label="mapPartitions"; 154126 [id="node_154126" labelType="html" label="MapPartitionsRDD [154126] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385454 { id="cluster_385454"; isCluster="true"; label="union"; 154127 [id="node_154127" labelType="html" label="UnionRDD [154127] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385455 { id="cluster_385455"; isCluster="true"; label="keyBy"; 154128 [id="node_154128" labelType="html" label="MapPartitionsRDD [154128] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 153986->153987; 153987->153988; 154068->154069; 154069->154070; 154070->154121; 154121->154122; 154122->154123; 154123->154124; 154124->154125; 154125->154126; 153988->154127; 154126->154127; 154127->154128; }

153985,153986

154067,154068

153988

154070

153986

153987

153988

154127

154128

digraph G { id="graph_341160"; subgraph graph_stage_341160 { id="graph_stage_341160"; isCluster="true"; label="Stage 341160 (skipped)"; 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_341161"; subgraph graph_stage_341161 { id="graph_stage_341161"; isCluster="true"; label="Stage 341161 (skipped)"; 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_341162"; subgraph graph_stage_341162 { id="graph_stage_341162"; isCluster="true"; label="Stage 341162 (skipped)"; subgraph cluster_385456 { id="cluster_385456"; isCluster="true"; label="reduceByKey"; 154129 [id="node_154129" labelType="html" label="ShuffledRDD [154129] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385457 { id="cluster_385457"; isCluster="true"; label="map"; 154130 [id="node_154130" labelType="html" label="MapPartitionsRDD [154130] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385458 { id="cluster_385458"; isCluster="true"; label="repartition"; 154131 [id="node_154131" labelType="html" label="MapPartitionsRDD [154131] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 154129->154130; 154130->154131; }

154128,154129

154129

154130

154131

digraph G { id="graph_341163"; subgraph graph_stage_341163 { id="graph_stage_341163"; isCluster="true"; label="Stage 341163"; 154140 [id="node_154140" labelType="html" label="SQLExecutionRDD [154140] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 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}"]; } subgraph cluster_385458 { id="cluster_385458"; isCluster="true"; label="repartition"; 154132 [id="node_154132" labelType="html" label="ShuffledRDD [154132] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154133 [id="node_154133" labelType="html" label="CoalescedRDD [154133] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154134 [id="node_154134" labelType="html" label="MapPartitionsRDD [154134] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385519 { id="cluster_385519"; isCluster="true"; label="InMemoryTableScan"; 154136 [id="node_154136" labelType="html" label="MapPartitionsRDD [154136] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154137 [id="node_154137" labelType="html" label="MapPartitionsRDD [154137] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154138 [id="node_154138" labelType="html" label="MapPartitionsRDD [154138] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385518 { id="cluster_385518"; isCluster="true"; label="DeserializeToObject"; 154139 [id="node_154139" labelType="html" label="MapPartitionsRDD [154139] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385520 { id="cluster_385520"; isCluster="true"; label="mapPartitions"; 154141 [id="node_154141" labelType="html" label="MapPartitionsRDD [154141] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385521 { id="cluster_385521"; isCluster="true"; label="union"; 154142 [id="node_154142" labelType="html" label="UnionRDD [154142] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385522 { id="cluster_385522"; isCluster="true"; label="keyBy"; 154143 [id="node_154143" labelType="html" label="MapPartitionsRDD [154143] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 154110->154111; 154111->154112; 154132->154133; 154133->154134; 154112->154136; 154136->154137; 154137->154138; 154138->154139; 154139->154140; 154140->154141; 154134->154142; 154141->154142; 154142->154143; }

154109,154110

154131,154132

154112

154134

154132

154133

154134

154142

154143

digraph G { id="graph_341164"; subgraph graph_stage_341164 { id="graph_stage_341164"; isCluster="true"; label="Stage 341164"; subgraph cluster_385523 { id="cluster_385523"; isCluster="true"; label="reduceByKey"; 154144 [id="node_154144" labelType="html" label="ShuffledRDD [154144] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385532 { id="cluster_385532"; isCluster="true"; label="map"; 154145 [id="node_154145" labelType="html" label="MapPartitionsRDD [154145] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385533 { id="cluster_385533"; isCluster="true"; label="repartition"; 154146 [id="node_154146" labelType="html" label="MapPartitionsRDD [154146] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 154144->154145; 154145->154146; }

154143,154144

154144

154145

154146

digraph G { id="graph_341165"; subgraph graph_stage_341165 { id="graph_stage_341165"; isCluster="true"; label="Stage 341165"; subgraph cluster_385533 { id="cluster_385533"; isCluster="true"; label="repartition"; 154147 [id="node_154147" labelType="html" label="ShuffledRDD [154147] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154148 [id="node_154148" labelType="html" label="CoalescedRDD [154148] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154149 [id="node_154149" labelType="html" label="MapPartitionsRDD [154149] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 154147->154148; 154148->154149; }

154146,154147

154149

154147

154148

154149

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Shuffle Read	Shuffle Write
341165	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:32	6 s	30/30		108.9 MiB
341164	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:26	6 s	37/37		101.4 MiB	108.9 MiB
341163	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:21	6 s	60/60	74.7 MiB		101.4 MiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

341165

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:32

6 s

30/30

108.9 MiB

341164

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:26

6 s

37/37

101.4 MiB

108.9 MiB

341163

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:21

6 s

60/60

74.7 MiB

101.4 MiB

Page:

Skipped Stages (9)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
341162	default	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)	Unknown	Unknown	0/37
341161	default	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)	Unknown	Unknown	0/30
341160	default	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)	Unknown	Unknown	0/30
341159	default	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)	Unknown	Unknown	0/60
341158	default	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)	Unknown	Unknown	0/30
341157	default	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)	Unknown	Unknown	0/30
341156	default	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)	Unknown	Unknown	0/30
341155	default	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)	Unknown	Unknown	0/30
341154	default	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)	Unknown	Unknown	0/30

Page: