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

Status: SUCCEEDED
Submitted: 2026/08/31 14:22:38
Duration: 20 s
Associated SQL Query: 13515
Job Group: 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d
Completed Stages: 3
Skipped Stages: 13

Enable zooming

digraph G { id="graph_341197"; subgraph graph_stage_341197 { id="graph_stage_341197"; isCluster="true"; label="Stage 341197 (skipped)"; 154082 [id="node_154082" labelType="html" label="SQLExecutionRDD [154082] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_385389 { id="cluster_385389"; isCluster="true"; label="Scan parquet "; 154079 [id="node_154079" labelType="html" label="FileScanRDD [154079] start at FileStorageAdapterImpl.java:596}"]; 154080 [id="node_154080" labelType="html" label="MapPartitionsRDD [154080] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385386 { id="cluster_385386"; isCluster="true"; label="WholeStageCodegen (1)"; 154081 [id="node_154081" labelType="html" label="MapPartitionsRDD [154081] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385404 { id="cluster_385404"; isCluster="true"; label="WholeStageCodegen (1)"; 154083 [id="node_154083" labelType="html" label="MapPartitionsRDD [154083] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385403 { id="cluster_385403"; isCluster="true"; label="HashAggregate"; 154084 [id="node_154084" labelType="html" label="MapPartitionsRDD [154084] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385402 { id="cluster_385402"; isCluster="true"; label="Exchange"; 154085 [id="node_154085" labelType="html" label="MapPartitionsRDD [154085] start at FileStorageAdapterImpl.java:596}"]; } } 154079->154080; 154080->154081; 154081->154082; 154082->154083; 154083->154084; 154084->154085; }

digraph G { id="graph_341198"; subgraph graph_stage_341198 { id="graph_stage_341198"; isCluster="true"; label="Stage 341198 (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_341199"; subgraph graph_stage_341199 { id="graph_stage_341199"; isCluster="true"; label="Stage 341199 (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_341200"; subgraph graph_stage_341200 { id="graph_stage_341200"; isCluster="true"; label="Stage 341200 (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_341201"; subgraph graph_stage_341201 { id="graph_stage_341201"; isCluster="true"; label="Stage 341201 (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_341202"; subgraph graph_stage_341202 { id="graph_stage_341202"; isCluster="true"; label="Stage 341202 (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_341203"; subgraph graph_stage_341203 { id="graph_stage_341203"; isCluster="true"; label="Stage 341203 (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] [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

153986

153987

153988

154127

154128

digraph G { id="graph_341204"; subgraph graph_stage_341204 { id="graph_stage_341204"; isCluster="true"; label="Stage 341204 (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_341205"; subgraph graph_stage_341205 { id="graph_stage_341205"; isCluster="true"; label="Stage 341205 (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_341206"; subgraph graph_stage_341206 { id="graph_stage_341206"; isCluster="true"; label="Stage 341206 (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_341207"; subgraph graph_stage_341207 { id="graph_stage_341207"; isCluster="true"; label="Stage 341207 (skipped)"; 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_341208"; subgraph graph_stage_341208 { id="graph_stage_341208"; isCluster="true"; label="Stage 341208 (skipped)"; 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_341209"; subgraph graph_stage_341209 { id="graph_stage_341209"; isCluster="true"; label="Stage 341209 (skipped)"; subgraph cluster_385402 { id="cluster_385402"; isCluster="true"; label="Exchange"; 154086 [id="node_154086" labelType="html" label="ShuffledRowRDD [154086] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385399 { id="cluster_385399"; isCluster="true"; label="WholeStageCodegen (2)"; 154087 [id="node_154087" labelType="html" label="MapPartitionsRDD [154087] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385398 { id="cluster_385398"; isCluster="true"; label="Exchange"; 154088 [id="node_154088" labelType="html" label="MapPartitionsRDD [154088] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 154086->154087; 154087->154088; }

154085,154086

digraph G { id="graph_341210"; subgraph graph_stage_341210 { id="graph_stage_341210"; isCluster="true"; label="Stage 341210"; 154215 [id="node_154215" labelType="html" label="SQLExecutionRDD [154215] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_385398 { id="cluster_385398"; isCluster="true"; label="Exchange"; 154089 [id="node_154089" labelType="html" label="ShuffledRowRDD [154089] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385397 { id="cluster_385397"; isCluster="true"; label="InMemoryTableScan"; 154090 [id="node_154090" labelType="html" label="MapPartitionsRDD [154090] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154091 [id="node_154091" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3614461L, 30), REPARTITION_BY_NUM, [plan_id=1034705]\n+- *(2) HashAggregate(keys=[demandChannel#3614464, shardId#3614460, kpis#3614466, version#3614462, qty#3614463, worklistShardItemId#3614461L, demandStream#3614465], functions=[], output=[shardId#3614460, worklistShardItemId#3614461L, version#3614462, qty#3614463, demandChannel#3614464, demandStream#3614465, kpis#3614466])\n +- Exchange hashpartitioning(demandChannel#3614464, shardId#3614460, kpis#3614466, version#3614462, qty#3614463, worklistShardItemId#3614461L, demandStream#3614465, 30), ENSURE_REQUIREMENTS, [plan_id=1034701]\n +- HashAggregate(keys=[demandChannel#3614464, shardId#3614460, knownfloatingpointnormalized(transform(kpis#3614466, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3614876)) null else named_struct(label, lambda arg#3614876.label, dateTime, lambda arg#3614876.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3614876.value)))), lambda ... [154091] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } 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}"]; } subgraph cluster_385679 { id="cluster_385679"; isCluster="true"; label="InMemoryTableScan"; 154211 [id="node_154211" labelType="html" label="MapPartitionsRDD [154211] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154212 [id="node_154212" labelType="html" label="MapPartitionsRDD [154212] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 154213 [id="node_154213" labelType="html" label="MapPartitionsRDD [154213] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385678 { id="cluster_385678"; isCluster="true"; label="DeserializeToObject"; 154214 [id="node_154214" labelType="html" label="MapPartitionsRDD [154214] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385680 { id="cluster_385680"; isCluster="true"; label="mapPartitions"; 154216 [id="node_154216" labelType="html" label="MapPartitionsRDD [154216] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385681 { id="cluster_385681"; isCluster="true"; label="union"; 154217 [id="node_154217" labelType="html" label="UnionRDD [154217] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385682 { id="cluster_385682"; isCluster="true"; label="keyBy"; 154218 [id="node_154218" labelType="html" label="MapPartitionsRDD [154218] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 154089->154090; 154090->154091; 154147->154148; 154148->154149; 154091->154211; 154211->154212; 154212->154213; 154213->154214; 154214->154215; 154215->154216; 154149->154217; 154216->154217; 154217->154218; }

154088,154089

154146,154147

154091

154149

154147

154148

154149

154217

154218

digraph G { id="graph_341211"; subgraph graph_stage_341211 { id="graph_stage_341211"; isCluster="true"; label="Stage 341211"; subgraph cluster_385691 { id="cluster_385691"; isCluster="true"; label="reduceByKey"; 154219 [id="node_154219" labelType="html" label="ShuffledRDD [154219] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385692 { id="cluster_385692"; isCluster="true"; label="map"; 154220 [id="node_154220" labelType="html" label="MapPartitionsRDD [154220] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385693 { id="cluster_385693"; isCluster="true"; label="repartition"; 154221 [id="node_154221" labelType="html" label="MapPartitionsRDD [154221] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 154219->154220; 154220->154221; }

154218,154219

154219

154220

154221

digraph G { id="graph_341212"; subgraph graph_stage_341212 { id="graph_stage_341212"; isCluster="true"; label="Stage 341212"; subgraph cluster_385693 { id="cluster_385693"; isCluster="true"; label="repartition"; 154222 [id="node_154222" labelType="html" label="ShuffledRDD [154222] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154223 [id="node_154223" labelType="html" label="CoalescedRDD [154223] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 154224 [id="node_154224" labelType="html" label="MapPartitionsRDD [154224] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 154222->154223; 154223->154224; }

154221,154222

154224

154222

154223

154224

Completed Stages (3)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Shuffle Read	Shuffle Write
341212	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d batch = 17 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:52	6 s	30/30		158.1 MiB
341211	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d batch = 17 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:45	7 s	37/37		149.2 MiB	158.1 MiB
341210	tenants-pool-506	stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d batch = 17 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:38	7 s	60/60	114.8 MiB		149.2 MiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

341212

tenants-pool-506

stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d batch = 17 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:52

6 s

30/30

158.1 MiB

341211

tenants-pool-506

stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d batch = 17 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:45

7 s

37/37

149.2 MiB

158.1 MiB

341210

tenants-pool-506

stream-10000000532-2 id = e64f0263-c3bb-4763-91e4-c179b778340d runId = 39a27bb9-6f6b-4c77-8aa6-9a13f7e5626d batch = 17 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:38

7 s

60/60

114.8 MiB

149.2 MiB

Page:

Skipped Stages (13)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
341209	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
341208	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
341207	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
341206	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
341205	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
341204	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
341203	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
341202	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
341201	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
341200	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
341199	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
341198	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
341197	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: