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

Status: SUCCEEDED
Submitted: 2026/09/02 14:13:53
Duration: 2 s
Completed Stages: 1
Skipped Stages: 31

Enable zooming

digraph G { id="graph_1657890"; subgraph graph_stage_1657890 { id="graph_stage_1657890"; isCluster="true"; label="Stage 1657890 (skipped)"; 709856 [id="node_709856" labelType="html" label="SQLExecutionRDD [709856] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1779620 { id="cluster_1779620"; isCluster="true"; label="Scan parquet "; 709853 [id="node_709853" labelType="html" label="FileScanRDD [709853] start at FileStorageAdapterImpl.java:596}"]; 709854 [id="node_709854" labelType="html" label="MapPartitionsRDD [709854] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779617 { id="cluster_1779617"; isCluster="true"; label="WholeStageCodegen (1)"; 709855 [id="node_709855" labelType="html" label="MapPartitionsRDD [709855] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779635 { id="cluster_1779635"; isCluster="true"; label="WholeStageCodegen (1)"; 709857 [id="node_709857" labelType="html" label="MapPartitionsRDD [709857] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779634 { id="cluster_1779634"; isCluster="true"; label="HashAggregate"; 709858 [id="node_709858" labelType="html" label="MapPartitionsRDD [709858] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779633 { id="cluster_1779633"; isCluster="true"; label="Exchange"; 709859 [id="node_709859" labelType="html" label="MapPartitionsRDD [709859] start at FileStorageAdapterImpl.java:596}"]; } } 709853->709854; 709854->709855; 709855->709856; 709856->709857; 709857->709858; 709858->709859; }

digraph G { id="graph_1657891"; subgraph graph_stage_1657891 { id="graph_stage_1657891"; isCluster="true"; label="Stage 1657891 (skipped)"; 709760 [id="node_709760" labelType="html" label="SQLExecutionRDD [709760] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1779417 { id="cluster_1779417"; isCluster="true"; label="Scan parquet "; 709757 [id="node_709757" labelType="html" label="FileScanRDD [709757] start at FileStorageAdapterImpl.java:596}"]; 709758 [id="node_709758" labelType="html" label="MapPartitionsRDD [709758] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779414 { id="cluster_1779414"; isCluster="true"; label="WholeStageCodegen (1)"; 709759 [id="node_709759" labelType="html" label="MapPartitionsRDD [709759] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779432 { id="cluster_1779432"; isCluster="true"; label="WholeStageCodegen (1)"; 709761 [id="node_709761" labelType="html" label="MapPartitionsRDD [709761] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779431 { id="cluster_1779431"; isCluster="true"; label="HashAggregate"; 709762 [id="node_709762" labelType="html" label="MapPartitionsRDD [709762] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779430 { id="cluster_1779430"; isCluster="true"; label="Exchange"; 709763 [id="node_709763" labelType="html" label="MapPartitionsRDD [709763] start at FileStorageAdapterImpl.java:596}"]; } } 709757->709758; 709758->709759; 709759->709760; 709760->709761; 709761->709762; 709762->709763; }

digraph G { id="graph_1657892"; subgraph graph_stage_1657892 { id="graph_stage_1657892"; isCluster="true"; label="Stage 1657892 (skipped)"; 709725 [id="node_709725" labelType="html" label="SQLExecutionRDD [709725] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1779366 { id="cluster_1779366"; isCluster="true"; label="Scan parquet "; 709722 [id="node_709722" labelType="html" label="FileScanRDD [709722] start at FileStorageAdapterImpl.java:596}"]; 709723 [id="node_709723" labelType="html" label="MapPartitionsRDD [709723] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779363 { id="cluster_1779363"; isCluster="true"; label="WholeStageCodegen (1)"; 709724 [id="node_709724" labelType="html" label="MapPartitionsRDD [709724] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779381 { id="cluster_1779381"; isCluster="true"; label="WholeStageCodegen (1)"; 709726 [id="node_709726" labelType="html" label="MapPartitionsRDD [709726] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779380 { id="cluster_1779380"; isCluster="true"; label="HashAggregate"; 709727 [id="node_709727" labelType="html" label="MapPartitionsRDD [709727] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779379 { id="cluster_1779379"; isCluster="true"; label="Exchange"; 709728 [id="node_709728" labelType="html" label="MapPartitionsRDD [709728] start at FileStorageAdapterImpl.java:596}"]; } } 709722->709723; 709723->709724; 709724->709725; 709725->709726; 709726->709727; 709727->709728; }

digraph G { id="graph_1657893"; subgraph graph_stage_1657893 { id="graph_stage_1657893"; isCluster="true"; label="Stage 1657893 (skipped)"; 707246 [id="node_707246" labelType="html" label="SQLExecutionRDD [707246] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1773192 { id="cluster_1773192"; isCluster="true"; label="Scan parquet "; 707243 [id="node_707243" labelType="html" label="FileScanRDD [707243] start at FileStorageAdapterImpl.java:596}"]; 707244 [id="node_707244" labelType="html" label="MapPartitionsRDD [707244] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1773189 { id="cluster_1773189"; isCluster="true"; label="WholeStageCodegen (1)"; 707245 [id="node_707245" labelType="html" label="MapPartitionsRDD [707245] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1773207 { id="cluster_1773207"; isCluster="true"; label="WholeStageCodegen (1)"; 707247 [id="node_707247" labelType="html" label="MapPartitionsRDD [707247] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1773206 { id="cluster_1773206"; isCluster="true"; label="HashAggregate"; 707248 [id="node_707248" labelType="html" label="MapPartitionsRDD [707248] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1773205 { id="cluster_1773205"; isCluster="true"; label="Exchange"; 707249 [id="node_707249" labelType="html" label="MapPartitionsRDD [707249] start at FileStorageAdapterImpl.java:596}"]; } } 707243->707244; 707244->707245; 707245->707246; 707246->707247; 707247->707248; 707248->707249; }

digraph G { id="graph_1657894"; subgraph graph_stage_1657894 { id="graph_stage_1657894"; isCluster="true"; label="Stage 1657894 (skipped)"; subgraph cluster_1773205 { id="cluster_1773205"; isCluster="true"; label="Exchange"; 707250 [id="node_707250" labelType="html" label="ShuffledRowRDD [707250] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1773202 { id="cluster_1773202"; isCluster="true"; label="WholeStageCodegen (2)"; 707251 [id="node_707251" labelType="html" label="MapPartitionsRDD [707251] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1773201 { id="cluster_1773201"; isCluster="true"; label="Exchange"; 707252 [id="node_707252" labelType="html" label="MapPartitionsRDD [707252] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 707250->707251; 707251->707252; }

707249,707250

digraph G { id="graph_1657895"; subgraph graph_stage_1657895 { id="graph_stage_1657895"; isCluster="true"; label="Stage 1657895 (skipped)"; 707268 [id="node_707268" labelType="html" label="SQLExecutionRDD [707268] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1772944 { id="cluster_1772944"; isCluster="true"; label="map"; 707146 [id="node_707146" labelType="html" label="MapPartitionsRDD [707146] [Cached] [Indeterminate] map at PeriodicAsyncRDDCheckpointWriterImpl.java:207}"]; } subgraph cluster_1772985 { id="cluster_1772985"; isCluster="true"; label="checkpoint"; 707167 [id="node_707167" labelType="html" label="LocalCheckpointRDD [707167] count at KpiCurveCacheImpl.java:255}"]; } subgraph cluster_1773201 { id="cluster_1773201"; isCluster="true"; label="Exchange"; 707253 [id="node_707253" labelType="html" label="ShuffledRowRDD [707253] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1773200 { id="cluster_1773200"; isCluster="true"; label="InMemoryTableScan"; 707254 [id="node_707254" labelType="html" label="MapPartitionsRDD [707254] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 707255 [id="node_707255" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#16504898L, 30), REPARTITION_BY_NUM, [plan_id=4947686]\n+- *(2) HashAggregate(keys=[demandChannel#16504901, shardId#16504897, kpis#16504903, version#16504899, qty#16504900, worklistShardItemId#16504898L, demandStream#16504902], functions=[], output=[shardId#16504897, worklistShardItemId#16504898L, version#16504899, qty#16504900, demandChannel#16504901, demandStream#16504902, kpis#16504903])\n +- Exchange hashpartitioning(demandChannel#16504901, shardId#16504897, kpis#16504903, version#16504899, qty#16504900, worklistShardItemId#16504898L, demandStream#16504902, 30), ENSURE_REQUIREMENTS, [plan_id=4947682]\n +- HashAggregate(keys=[demandChannel#16504901, shardId#16504897, knownfloatingpointnormalized(transform(kpis#16504903, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#16633615)) null else named_struct(label, lambda arg#16633615.label, dateTime, lambda arg#16633615.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [707255] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1773233 { id="cluster_1773233"; isCluster="true"; label="InMemoryTableScan"; 707264 [id="node_707264" labelType="html" label="MapPartitionsRDD [707264] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 707265 [id="node_707265" labelType="html" label="MapPartitionsRDD [707265] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 707266 [id="node_707266" labelType="html" label="MapPartitionsRDD [707266] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1773232 { id="cluster_1773232"; isCluster="true"; label="DeserializeToObject"; 707267 [id="node_707267" labelType="html" label="MapPartitionsRDD [707267] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1773234 { id="cluster_1773234"; isCluster="true"; label="mapPartitions"; 707269 [id="node_707269" labelType="html" label="MapPartitionsRDD [707269] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1773235 { id="cluster_1773235"; isCluster="true"; label="union"; 707270 [id="node_707270" labelType="html" label="UnionRDD [707270] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1773236 { id="cluster_1773236"; isCluster="true"; label="keyBy"; 707271 [id="node_707271" labelType="html" label="MapPartitionsRDD [707271] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 707167->707146; 707253->707254; 707254->707255; 707255->707264; 707264->707265; 707265->707266; 707266->707267; 707267->707268; 707268->707269; 707146->707270; 707269->707270; 707270->707271; }

707252,707253

707146

707270

707271

digraph G { id="graph_1657896"; subgraph graph_stage_1657896 { id="graph_stage_1657896"; isCluster="true"; label="Stage 1657896 (skipped)"; subgraph cluster_1773237 { id="cluster_1773237"; isCluster="true"; label="reduceByKey"; 707272 [id="node_707272" labelType="html" label="ShuffledRDD [707272] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1773238 { id="cluster_1773238"; isCluster="true"; label="map"; 707273 [id="node_707273" labelType="html" label="MapPartitionsRDD [707273] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1773239 { id="cluster_1773239"; isCluster="true"; label="repartition"; 707274 [id="node_707274" labelType="html" label="MapPartitionsRDD [707274] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 707272->707273; 707273->707274; }

707271,707272

707272

707273

707274

digraph G { id="graph_1657897"; subgraph graph_stage_1657897 { id="graph_stage_1657897"; isCluster="true"; label="Stage 1657897 (skipped)"; 707860 [id="node_707860" labelType="html" label="SQLExecutionRDD [707860] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1773239 { id="cluster_1773239"; isCluster="true"; label="repartition"; 707275 [id="node_707275" labelType="html" label="ShuffledRDD [707275] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 707276 [id="node_707276" labelType="html" label="CoalescedRDD [707276] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 707277 [id="node_707277" labelType="html" label="MapPartitionsRDD [707277] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1774759 { id="cluster_1774759"; isCluster="true"; label="map"; 707857 [id="node_707857" labelType="html" label="MapPartitionsRDD [707857] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1774761 { id="cluster_1774761"; isCluster="true"; label="WholeStageCodegen (1)"; 707858 [id="node_707858" labelType="html" label="MapPartitionsRDD [707858] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1774760 { id="cluster_1774760"; isCluster="true"; label="DeserializeToObject"; 707859 [id="node_707859" labelType="html" label="MapPartitionsRDD [707859] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1774764 { id="cluster_1774764"; isCluster="true"; label="mapPartitions"; 707861 [id="node_707861" labelType="html" label="MapPartitionsRDD [707861] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1774765 { id="cluster_1774765"; isCluster="true"; label="repartition"; 707862 [id="node_707862" labelType="html" label="MapPartitionsRDD [707862] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 707275->707276; 707276->707277; 707277->707857; 707857->707858; 707858->707859; 707859->707860; 707860->707861; 707861->707862; }

707274,707275

707277

707860

707275

707276

707277

707857

707858

707859

707861

707862

digraph G { id="graph_1657898"; subgraph graph_stage_1657898 { id="graph_stage_1657898"; isCluster="true"; label="Stage 1657898 (skipped)"; 707874 [id="node_707874" labelType="html" label="SQLExecutionRDD [707874] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; subgraph cluster_1774765 { id="cluster_1774765"; isCluster="true"; label="repartition"; 707863 [id="node_707863" labelType="html" label="ShuffledRDD [707863] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 707864 [id="node_707864" labelType="html" label="CoalescedRDD [707864] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 707865 [id="node_707865" labelType="html" label="MapPartitionsRDD [707865] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1774785 { id="cluster_1774785"; isCluster="true"; label="map"; 707870 [id="node_707870" labelType="html" label="MapPartitionsRDD [707870] [Indeterminate] createDataFrame at KpiCurveCacheImpl.java:230}"]; } subgraph cluster_1774788 { id="cluster_1774788"; isCluster="true"; label="WholeStageCodegen (1)"; 707872 [id="node_707872" labelType="html" label="MapPartitionsRDD [707872] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1774787 { id="cluster_1774787"; isCluster="true"; label="DeserializeToObject"; 707873 [id="node_707873" labelType="html" label="MapPartitionsRDD [707873] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1774795 { id="cluster_1774795"; isCluster="true"; label="mapPartitions"; 707875 [id="node_707875" labelType="html" label="MapPartitionsRDD [707875] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1774796 { id="cluster_1774796"; isCluster="true"; label="repartition"; 707876 [id="node_707876" labelType="html" label="MapPartitionsRDD [707876] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } } 707863->707864; 707864->707865; 707865->707870; 707870->707872; 707872->707873; 707873->707874; 707874->707875; 707875->707876; }

707862,707863

707865

707874

707863

707864

707865

707870

707872

707873

707875

707876

digraph G { id="graph_1657899"; subgraph graph_stage_1657899 { id="graph_stage_1657899"; isCluster="true"; label="Stage 1657899 (skipped)"; 708194 [id="node_708194" labelType="html" label="SQLExecutionRDD [708194] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1775559 { id="cluster_1775559"; isCluster="true"; label="Scan parquet "; 708191 [id="node_708191" labelType="html" label="FileScanRDD [708191] start at FileStorageAdapterImpl.java:596}"]; 708192 [id="node_708192" labelType="html" label="MapPartitionsRDD [708192] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1775556 { id="cluster_1775556"; isCluster="true"; label="WholeStageCodegen (1)"; 708193 [id="node_708193" labelType="html" label="MapPartitionsRDD [708193] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1775574 { id="cluster_1775574"; isCluster="true"; label="WholeStageCodegen (1)"; 708195 [id="node_708195" labelType="html" label="MapPartitionsRDD [708195] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1775573 { id="cluster_1775573"; isCluster="true"; label="HashAggregate"; 708196 [id="node_708196" labelType="html" label="MapPartitionsRDD [708196] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1775572 { id="cluster_1775572"; isCluster="true"; label="Exchange"; 708197 [id="node_708197" labelType="html" label="MapPartitionsRDD [708197] start at FileStorageAdapterImpl.java:596}"]; } } 708191->708192; 708192->708193; 708193->708194; 708194->708195; 708195->708196; 708196->708197; }

digraph G { id="graph_1657900"; subgraph graph_stage_1657900 { id="graph_stage_1657900"; isCluster="true"; label="Stage 1657900 (skipped)"; subgraph cluster_1775572 { id="cluster_1775572"; isCluster="true"; label="Exchange"; 708198 [id="node_708198" labelType="html" label="ShuffledRowRDD [708198] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1775569 { id="cluster_1775569"; isCluster="true"; label="WholeStageCodegen (2)"; 708199 [id="node_708199" labelType="html" label="MapPartitionsRDD [708199] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1775568 { id="cluster_1775568"; isCluster="true"; label="Exchange"; 708200 [id="node_708200" labelType="html" label="MapPartitionsRDD [708200] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 708198->708199; 708199->708200; }

708197,708198

digraph G { id="graph_1657901"; subgraph graph_stage_1657901 { id="graph_stage_1657901"; isCluster="true"; label="Stage 1657901 (skipped)"; 707967 [id="node_707967" labelType="html" label="SQLExecutionRDD [707967] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; subgraph cluster_1774796 { id="cluster_1774796"; isCluster="true"; label="repartition"; 707877 [id="node_707877" labelType="html" label="ShuffledRDD [707877] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 707878 [id="node_707878" labelType="html" label="CoalescedRDD [707878] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 707879 [id="node_707879" labelType="html" label="MapPartitionsRDD [707879] [Cached] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } subgraph cluster_1774975 { id="cluster_1774975"; isCluster="true"; label="map"; 707964 [id="node_707964" labelType="html" label="MapPartitionsRDD [707964] [Indeterminate] createDataFrame at KpiCurveCacheImpl.java:230}"]; } subgraph cluster_1774977 { id="cluster_1774977"; isCluster="true"; label="WholeStageCodegen (1)"; 707965 [id="node_707965" labelType="html" label="MapPartitionsRDD [707965] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1774976 { id="cluster_1774976"; isCluster="true"; label="DeserializeToObject"; 707966 [id="node_707966" labelType="html" label="MapPartitionsRDD [707966] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1774980 { id="cluster_1774980"; isCluster="true"; label="mapPartitions"; 707968 [id="node_707968" labelType="html" label="MapPartitionsRDD [707968] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1774981 { id="cluster_1774981"; isCluster="true"; label="repartition"; 707969 [id="node_707969" labelType="html" label="MapPartitionsRDD [707969] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } } 707877->707878; 707878->707879; 707879->707964; 707964->707965; 707965->707966; 707966->707967; 707967->707968; 707968->707969; }

707876,707877

707879

707967

707877

707878

707879

707964

707965

707966

707968

707969

digraph G { id="graph_1657902"; subgraph graph_stage_1657902 { id="graph_stage_1657902"; isCluster="true"; label="Stage 1657902 (skipped)"; 708216 [id="node_708216" labelType="html" label="SQLExecutionRDD [708216] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1774981 { id="cluster_1774981"; isCluster="true"; label="repartition"; 707970 [id="node_707970" labelType="html" label="ShuffledRDD [707970] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 707971 [id="node_707971" labelType="html" label="CoalescedRDD [707971] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 707972 [id="node_707972" labelType="html" label="MapPartitionsRDD [707972] [Cached] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } subgraph cluster_1775568 { id="cluster_1775568"; isCluster="true"; label="Exchange"; 708201 [id="node_708201" labelType="html" label="ShuffledRowRDD [708201] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1775567 { id="cluster_1775567"; isCluster="true"; label="InMemoryTableScan"; 708202 [id="node_708202" labelType="html" label="MapPartitionsRDD [708202] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 708203 [id="node_708203" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#16504898L, 30), REPARTITION_BY_NUM, [plan_id=4954038]\n+- *(2) HashAggregate(keys=[demandChannel#16504901, shardId#16504897, kpis#16504903, version#16504899, qty#16504900, worklistShardItemId#16504898L, demandStream#16504902], functions=[], output=[shardId#16504897, worklistShardItemId#16504898L, version#16504899, qty#16504900, demandChannel#16504901, demandStream#16504902, kpis#16504903])\n +- Exchange hashpartitioning(demandChannel#16504901, shardId#16504897, kpis#16504903, version#16504899, qty#16504900, worklistShardItemId#16504898L, demandStream#16504902, 30), ENSURE_REQUIREMENTS, [plan_id=4954034]\n +- HashAggregate(keys=[demandChannel#16504901, shardId#16504897, knownfloatingpointnormalized(transform(kpis#16504903, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#16660172)) null else named_struct(label, lambda arg#16660172.label, dateTime, lambda arg#16660172.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [708203] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1775600 { id="cluster_1775600"; isCluster="true"; label="InMemoryTableScan"; 708212 [id="node_708212" labelType="html" label="MapPartitionsRDD [708212] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 708213 [id="node_708213" labelType="html" label="MapPartitionsRDD [708213] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 708214 [id="node_708214" labelType="html" label="MapPartitionsRDD [708214] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1775599 { id="cluster_1775599"; isCluster="true"; label="DeserializeToObject"; 708215 [id="node_708215" labelType="html" label="MapPartitionsRDD [708215] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1775601 { id="cluster_1775601"; isCluster="true"; label="mapPartitions"; 708217 [id="node_708217" labelType="html" label="MapPartitionsRDD [708217] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1775602 { id="cluster_1775602"; isCluster="true"; label="union"; 708218 [id="node_708218" labelType="html" label="UnionRDD [708218] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1775603 { id="cluster_1775603"; isCluster="true"; label="keyBy"; 708219 [id="node_708219" labelType="html" label="MapPartitionsRDD [708219] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 707970->707971; 707971->707972; 708201->708202; 708202->708203; 708203->708212; 708212->708213; 708213->708214; 708214->708215; 708215->708216; 708216->708217; 707972->708218; 708217->708218; 708218->708219; }

707969,707970

708200,708201

707972

707970

707971

707972

708218

708219

digraph G { id="graph_1657903"; subgraph graph_stage_1657903 { id="graph_stage_1657903"; isCluster="true"; label="Stage 1657903 (skipped)"; subgraph cluster_1775604 { id="cluster_1775604"; isCluster="true"; label="reduceByKey"; 708220 [id="node_708220" labelType="html" label="ShuffledRDD [708220] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1775605 { id="cluster_1775605"; isCluster="true"; label="map"; 708221 [id="node_708221" labelType="html" label="MapPartitionsRDD [708221] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1775606 { id="cluster_1775606"; isCluster="true"; label="repartition"; 708222 [id="node_708222" labelType="html" label="MapPartitionsRDD [708222] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 708220->708221; 708221->708222; }

708219,708220

708220

708221

708222

digraph G { id="graph_1657904"; subgraph graph_stage_1657904 { id="graph_stage_1657904"; isCluster="true"; label="Stage 1657904 (skipped)"; 708762 [id="node_708762" labelType="html" label="SQLExecutionRDD [708762] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1776976 { id="cluster_1776976"; isCluster="true"; label="Scan parquet "; 708759 [id="node_708759" labelType="html" label="FileScanRDD [708759] start at FileStorageAdapterImpl.java:596}"]; 708760 [id="node_708760" labelType="html" label="MapPartitionsRDD [708760] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1776973 { id="cluster_1776973"; isCluster="true"; label="WholeStageCodegen (1)"; 708761 [id="node_708761" labelType="html" label="MapPartitionsRDD [708761] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1776991 { id="cluster_1776991"; isCluster="true"; label="WholeStageCodegen (1)"; 708763 [id="node_708763" labelType="html" label="MapPartitionsRDD [708763] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1776990 { id="cluster_1776990"; isCluster="true"; label="HashAggregate"; 708764 [id="node_708764" labelType="html" label="MapPartitionsRDD [708764] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1776989 { id="cluster_1776989"; isCluster="true"; label="Exchange"; 708765 [id="node_708765" labelType="html" label="MapPartitionsRDD [708765] start at FileStorageAdapterImpl.java:596}"]; } } 708759->708760; 708760->708761; 708761->708762; 708762->708763; 708763->708764; 708764->708765; }

digraph G { id="graph_1657905"; subgraph graph_stage_1657905 { id="graph_stage_1657905"; isCluster="true"; label="Stage 1657905 (skipped)"; subgraph cluster_1776989 { id="cluster_1776989"; isCluster="true"; label="Exchange"; 708766 [id="node_708766" labelType="html" label="ShuffledRowRDD [708766] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1776986 { id="cluster_1776986"; isCluster="true"; label="WholeStageCodegen (2)"; 708767 [id="node_708767" labelType="html" label="MapPartitionsRDD [708767] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1776985 { id="cluster_1776985"; isCluster="true"; label="Exchange"; 708768 [id="node_708768" labelType="html" label="MapPartitionsRDD [708768] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 708766->708767; 708767->708768; }

708765,708766

digraph G { id="graph_1657906"; subgraph graph_stage_1657906 { id="graph_stage_1657906"; isCluster="true"; label="Stage 1657906 (skipped)"; 708297 [id="node_708297" labelType="html" label="SQLExecutionRDD [708297] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; subgraph cluster_1775606 { id="cluster_1775606"; isCluster="true"; label="repartition"; 708223 [id="node_708223" labelType="html" label="ShuffledRDD [708223] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 708224 [id="node_708224" labelType="html" label="CoalescedRDD [708224] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 708225 [id="node_708225" labelType="html" label="MapPartitionsRDD [708225] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1775783 { id="cluster_1775783"; isCluster="true"; label="map"; 708294 [id="node_708294" labelType="html" label="MapPartitionsRDD [708294] [Indeterminate] createDataFrame at KpiCurveCacheImpl.java:230}"]; } subgraph cluster_1775785 { id="cluster_1775785"; isCluster="true"; label="WholeStageCodegen (1)"; 708295 [id="node_708295" labelType="html" label="MapPartitionsRDD [708295] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1775784 { id="cluster_1775784"; isCluster="true"; label="DeserializeToObject"; 708296 [id="node_708296" labelType="html" label="MapPartitionsRDD [708296] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1775788 { id="cluster_1775788"; isCluster="true"; label="mapPartitions"; 708298 [id="node_708298" labelType="html" label="MapPartitionsRDD [708298] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1775789 { id="cluster_1775789"; isCluster="true"; label="repartition"; 708299 [id="node_708299" labelType="html" label="MapPartitionsRDD [708299] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } } 708223->708224; 708224->708225; 708225->708294; 708294->708295; 708295->708296; 708296->708297; 708297->708298; 708298->708299; }

708222,708223

708225

708297

708223

708224

708225

708294

708295

708296

708298

708299

digraph G { id="graph_1657907"; subgraph graph_stage_1657907 { id="graph_stage_1657907"; isCluster="true"; label="Stage 1657907 (skipped)"; 708799 [id="node_708799" labelType="html" label="SQLExecutionRDD [708799] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1775789 { id="cluster_1775789"; isCluster="true"; label="repartition"; 708300 [id="node_708300" labelType="html" label="ShuffledRDD [708300] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 708301 [id="node_708301" labelType="html" label="CoalescedRDD [708301] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 708302 [id="node_708302" labelType="html" label="MapPartitionsRDD [708302] [Cached] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } subgraph cluster_1776985 { id="cluster_1776985"; isCluster="true"; label="Exchange"; 708769 [id="node_708769" labelType="html" label="ShuffledRowRDD [708769] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1776984 { id="cluster_1776984"; isCluster="true"; label="InMemoryTableScan"; 708770 [id="node_708770" labelType="html" label="MapPartitionsRDD [708770] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 708771 [id="node_708771" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#16505221L, 30), REPARTITION_BY_NUM, [plan_id=4957730]\n+- *(2) HashAggregate(keys=[demandChannel#16505224, shardId#16505220, kpis#16505226, version#16505222, qty#16505223, worklistShardItemId#16505221L, demandStream#16505225], functions=[], output=[shardId#16505220, worklistShardItemId#16505221L, version#16505222, qty#16505223, demandChannel#16505224, demandStream#16505225, kpis#16505226])\n +- Exchange hashpartitioning(demandChannel#16505224, shardId#16505220, kpis#16505226, version#16505222, qty#16505223, worklistShardItemId#16505221L, demandStream#16505225, 30), ENSURE_REQUIREMENTS, [plan_id=4957726]\n +- HashAggregate(keys=[demandChannel#16505224, shardId#16505220, knownfloatingpointnormalized(transform(kpis#16505226, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#16672178)) null else named_struct(label, lambda arg#16672178.label, dateTime, lambda arg#16672178.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [708771] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1777051 { id="cluster_1777051"; isCluster="true"; label="InMemoryTableScan"; 708795 [id="node_708795" labelType="html" label="MapPartitionsRDD [708795] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 708796 [id="node_708796" labelType="html" label="MapPartitionsRDD [708796] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 708797 [id="node_708797" labelType="html" label="MapPartitionsRDD [708797] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1777050 { id="cluster_1777050"; isCluster="true"; label="DeserializeToObject"; 708798 [id="node_708798" labelType="html" label="MapPartitionsRDD [708798] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1777052 { id="cluster_1777052"; isCluster="true"; label="mapPartitions"; 708800 [id="node_708800" labelType="html" label="MapPartitionsRDD [708800] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1777053 { id="cluster_1777053"; isCluster="true"; label="union"; 708801 [id="node_708801" labelType="html" label="UnionRDD [708801] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1777054 { id="cluster_1777054"; isCluster="true"; label="keyBy"; 708802 [id="node_708802" labelType="html" label="MapPartitionsRDD [708802] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 708300->708301; 708301->708302; 708769->708770; 708770->708771; 708771->708795; 708795->708796; 708796->708797; 708797->708798; 708798->708799; 708799->708800; 708302->708801; 708800->708801; 708801->708802; }

708299,708300

708768,708769

708302

708300

708301

708302

708801

708802

digraph G { id="graph_1657908"; subgraph graph_stage_1657908 { id="graph_stage_1657908"; isCluster="true"; label="Stage 1657908 (skipped)"; subgraph cluster_1777055 { id="cluster_1777055"; isCluster="true"; label="reduceByKey"; 708803 [id="node_708803" labelType="html" label="ShuffledRDD [708803] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1777056 { id="cluster_1777056"; isCluster="true"; label="map"; 708804 [id="node_708804" labelType="html" label="MapPartitionsRDD [708804] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1777057 { id="cluster_1777057"; isCluster="true"; label="repartition"; 708805 [id="node_708805" labelType="html" label="MapPartitionsRDD [708805] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 708803->708804; 708804->708805; }

708802,708803

708803

708804

708805

digraph G { id="graph_1657909"; subgraph graph_stage_1657909 { id="graph_stage_1657909"; isCluster="true"; label="Stage 1657909 (skipped)"; 709196 [id="node_709196" labelType="html" label="SQLExecutionRDD [709196] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1777057 { id="cluster_1777057"; isCluster="true"; label="repartition"; 708806 [id="node_708806" labelType="html" label="ShuffledRDD [708806] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 708807 [id="node_708807" labelType="html" label="CoalescedRDD [708807] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 708808 [id="node_708808" labelType="html" label="MapPartitionsRDD [708808] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1778070 { id="cluster_1778070"; isCluster="true"; label="map"; 709193 [id="node_709193" labelType="html" label="MapPartitionsRDD [709193] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1778072 { id="cluster_1778072"; isCluster="true"; label="WholeStageCodegen (1)"; 709194 [id="node_709194" labelType="html" label="MapPartitionsRDD [709194] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1778071 { id="cluster_1778071"; isCluster="true"; label="DeserializeToObject"; 709195 [id="node_709195" labelType="html" label="MapPartitionsRDD [709195] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1778075 { id="cluster_1778075"; isCluster="true"; label="mapPartitions"; 709197 [id="node_709197" labelType="html" label="MapPartitionsRDD [709197] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1778076 { id="cluster_1778076"; isCluster="true"; label="repartition"; 709198 [id="node_709198" labelType="html" label="MapPartitionsRDD [709198] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 708806->708807; 708807->708808; 708808->709193; 709193->709194; 709194->709195; 709195->709196; 709196->709197; 709197->709198; }

708805,708806

708808

709196

708806

708807

708808

709193

709194

709195

709197

709198

digraph G { id="graph_1657910"; subgraph graph_stage_1657910 { id="graph_stage_1657910"; isCluster="true"; label="Stage 1657910 (skipped)"; 709647 [id="node_709647" labelType="html" label="SQLExecutionRDD [709647] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1778076 { id="cluster_1778076"; isCluster="true"; label="repartition"; 709199 [id="node_709199" labelType="html" label="ShuffledRDD [709199] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 709200 [id="node_709200" labelType="html" label="CoalescedRDD [709200] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 709201 [id="node_709201" labelType="html" label="MapPartitionsRDD [709201] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779207 { id="cluster_1779207"; isCluster="true"; label="map"; 709644 [id="node_709644" labelType="html" label="MapPartitionsRDD [709644] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779209 { id="cluster_1779209"; isCluster="true"; label="WholeStageCodegen (1)"; 709645 [id="node_709645" labelType="html" label="MapPartitionsRDD [709645] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779208 { id="cluster_1779208"; isCluster="true"; label="DeserializeToObject"; 709646 [id="node_709646" labelType="html" label="MapPartitionsRDD [709646] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779212 { id="cluster_1779212"; isCluster="true"; label="mapPartitions"; 709648 [id="node_709648" labelType="html" label="MapPartitionsRDD [709648] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779213 { id="cluster_1779213"; isCluster="true"; label="repartition"; 709649 [id="node_709649" labelType="html" label="MapPartitionsRDD [709649] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 709199->709200; 709200->709201; 709201->709644; 709644->709645; 709645->709646; 709646->709647; 709647->709648; 709648->709649; }

709198,709199

709201

709647

709199

709200

709201

709644

709645

709646

709648

709649

digraph G { id="graph_1657911"; subgraph graph_stage_1657911 { id="graph_stage_1657911"; isCluster="true"; label="Stage 1657911 (skipped)"; subgraph cluster_1779379 { id="cluster_1779379"; isCluster="true"; label="Exchange"; 709729 [id="node_709729" labelType="html" label="ShuffledRowRDD [709729] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779376 { id="cluster_1779376"; isCluster="true"; label="WholeStageCodegen (2)"; 709730 [id="node_709730" labelType="html" label="MapPartitionsRDD [709730] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779375 { id="cluster_1779375"; isCluster="true"; label="Exchange"; 709731 [id="node_709731" labelType="html" label="MapPartitionsRDD [709731] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 709729->709730; 709730->709731; }

709728,709729

digraph G { id="graph_1657912"; subgraph graph_stage_1657912 { id="graph_stage_1657912"; isCluster="true"; label="Stage 1657912 (skipped)"; 709747 [id="node_709747" labelType="html" label="SQLExecutionRDD [709747] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1779213 { id="cluster_1779213"; isCluster="true"; label="repartition"; 709650 [id="node_709650" labelType="html" label="ShuffledRDD [709650] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 709651 [id="node_709651" labelType="html" label="CoalescedRDD [709651] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 709652 [id="node_709652" labelType="html" label="MapPartitionsRDD [709652] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779375 { id="cluster_1779375"; isCluster="true"; label="Exchange"; 709732 [id="node_709732" labelType="html" label="ShuffledRowRDD [709732] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779374 { id="cluster_1779374"; isCluster="true"; label="InMemoryTableScan"; 709733 [id="node_709733" labelType="html" label="MapPartitionsRDD [709733] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709734 [id="node_709734" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#16691990L, 30), REPARTITION_BY_NUM, [plan_id=4962697]\n+- *(2) HashAggregate(keys=[demandChannel#16691993, shardId#16691989, kpis#16691995, version#16691991, qty#16691992, worklistShardItemId#16691990L, demandStream#16691994], functions=[], output=[shardId#16691989, worklistShardItemId#16691990L, version#16691991, qty#16691992, demandChannel#16691993, demandStream#16691994, kpis#16691995])\n +- Exchange hashpartitioning(demandChannel#16691993, shardId#16691989, kpis#16691995, version#16691991, qty#16691992, worklistShardItemId#16691990L, demandStream#16691994, 30), ENSURE_REQUIREMENTS, [plan_id=4962693]\n +- HashAggregate(keys=[demandChannel#16691993, shardId#16691989, knownfloatingpointnormalized(transform(kpis#16691995, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#16692082)) null else named_struct(label, lambda arg#16692082.label, dateTime, lambda arg#16692082.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [709734] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779407 { id="cluster_1779407"; isCluster="true"; label="InMemoryTableScan"; 709743 [id="node_709743" labelType="html" label="MapPartitionsRDD [709743] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709744 [id="node_709744" labelType="html" label="MapPartitionsRDD [709744] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709745 [id="node_709745" labelType="html" label="MapPartitionsRDD [709745] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779406 { id="cluster_1779406"; isCluster="true"; label="DeserializeToObject"; 709746 [id="node_709746" labelType="html" label="MapPartitionsRDD [709746] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779408 { id="cluster_1779408"; isCluster="true"; label="mapPartitions"; 709748 [id="node_709748" labelType="html" label="MapPartitionsRDD [709748] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779409 { id="cluster_1779409"; isCluster="true"; label="union"; 709749 [id="node_709749" labelType="html" label="UnionRDD [709749] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779410 { id="cluster_1779410"; isCluster="true"; label="keyBy"; 709750 [id="node_709750" labelType="html" label="MapPartitionsRDD [709750] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 709650->709651; 709651->709652; 709732->709733; 709733->709734; 709734->709743; 709743->709744; 709744->709745; 709745->709746; 709746->709747; 709747->709748; 709652->709749; 709748->709749; 709749->709750; }

709649,709650

709731,709732

709652

709650

709651

709652

709749

709750

digraph G { id="graph_1657913"; subgraph graph_stage_1657913 { id="graph_stage_1657913"; isCluster="true"; label="Stage 1657913 (skipped)"; subgraph cluster_1779411 { id="cluster_1779411"; isCluster="true"; label="reduceByKey"; 709751 [id="node_709751" labelType="html" label="ShuffledRDD [709751] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779412 { id="cluster_1779412"; isCluster="true"; label="map"; 709752 [id="node_709752" labelType="html" label="MapPartitionsRDD [709752] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779413 { id="cluster_1779413"; isCluster="true"; label="repartition"; 709753 [id="node_709753" labelType="html" label="MapPartitionsRDD [709753] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 709751->709752; 709752->709753; }

709750,709751

709751

709752

709753

digraph G { id="graph_1657914"; subgraph graph_stage_1657914 { id="graph_stage_1657914"; isCluster="true"; label="Stage 1657914 (skipped)"; subgraph cluster_1779430 { id="cluster_1779430"; isCluster="true"; label="Exchange"; 709764 [id="node_709764" labelType="html" label="ShuffledRowRDD [709764] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779427 { id="cluster_1779427"; isCluster="true"; label="WholeStageCodegen (2)"; 709765 [id="node_709765" labelType="html" label="MapPartitionsRDD [709765] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779426 { id="cluster_1779426"; isCluster="true"; label="Exchange"; 709766 [id="node_709766" labelType="html" label="MapPartitionsRDD [709766] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 709764->709765; 709765->709766; }

709763,709764

digraph G { id="graph_1657915"; subgraph graph_stage_1657915 { id="graph_stage_1657915"; isCluster="true"; label="Stage 1657915 (skipped)"; 709806 [id="node_709806" labelType="html" label="SQLExecutionRDD [709806] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1779413 { id="cluster_1779413"; isCluster="true"; label="repartition"; 709754 [id="node_709754" labelType="html" label="ShuffledRDD [709754] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 709755 [id="node_709755" labelType="html" label="CoalescedRDD [709755] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 709756 [id="node_709756" labelType="html" label="MapPartitionsRDD [709756] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779426 { id="cluster_1779426"; isCluster="true"; label="Exchange"; 709767 [id="node_709767" labelType="html" label="ShuffledRowRDD [709767] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779425 { id="cluster_1779425"; isCluster="true"; label="InMemoryTableScan"; 709768 [id="node_709768" labelType="html" label="MapPartitionsRDD [709768] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709769 [id="node_709769" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#16692472L, 30), REPARTITION_BY_NUM, [plan_id=4962784]\n+- *(2) HashAggregate(keys=[demandChannel#16692475, shardId#16692471, kpis#16692477, version#16692473, qty#16692474, worklistShardItemId#16692472L, demandStream#16692476], functions=[], output=[shardId#16692471, worklistShardItemId#16692472L, version#16692473, qty#16692474, demandChannel#16692475, demandStream#16692476, kpis#16692477])\n +- Exchange hashpartitioning(demandChannel#16692475, shardId#16692471, kpis#16692477, version#16692473, qty#16692474, worklistShardItemId#16692472L, demandStream#16692476, 30), ENSURE_REQUIREMENTS, [plan_id=4962780]\n +- HashAggregate(keys=[demandChannel#16692475, shardId#16692471, knownfloatingpointnormalized(transform(kpis#16692477, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#16692564)) null else named_struct(label, lambda arg#16692564.label, dateTime, lambda arg#16692564.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [709769] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779513 { id="cluster_1779513"; isCluster="true"; label="InMemoryTableScan"; 709802 [id="node_709802" labelType="html" label="MapPartitionsRDD [709802] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709803 [id="node_709803" labelType="html" label="MapPartitionsRDD [709803] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709804 [id="node_709804" labelType="html" label="MapPartitionsRDD [709804] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779512 { id="cluster_1779512"; isCluster="true"; label="DeserializeToObject"; 709805 [id="node_709805" labelType="html" label="MapPartitionsRDD [709805] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779514 { id="cluster_1779514"; isCluster="true"; label="mapPartitions"; 709807 [id="node_709807" labelType="html" label="MapPartitionsRDD [709807] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779515 { id="cluster_1779515"; isCluster="true"; label="union"; 709808 [id="node_709808" labelType="html" label="UnionRDD [709808] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779516 { id="cluster_1779516"; isCluster="true"; label="keyBy"; 709809 [id="node_709809" labelType="html" label="MapPartitionsRDD [709809] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 709754->709755; 709755->709756; 709767->709768; 709768->709769; 709769->709802; 709802->709803; 709803->709804; 709804->709805; 709805->709806; 709806->709807; 709756->709808; 709807->709808; 709808->709809; }

709753,709754

709766,709767

709756

709754

709755

709756

709808

709809

digraph G { id="graph_1657916"; subgraph graph_stage_1657916 { id="graph_stage_1657916"; isCluster="true"; label="Stage 1657916 (skipped)"; subgraph cluster_1779517 { id="cluster_1779517"; isCluster="true"; label="reduceByKey"; 709810 [id="node_709810" labelType="html" label="ShuffledRDD [709810] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779518 { id="cluster_1779518"; isCluster="true"; label="map"; 709811 [id="node_709811" labelType="html" label="MapPartitionsRDD [709811] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779519 { id="cluster_1779519"; isCluster="true"; label="repartition"; 709812 [id="node_709812" labelType="html" label="MapPartitionsRDD [709812] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 709810->709811; 709811->709812; }

709809,709810

709810

709811

709812

digraph G { id="graph_1657917"; subgraph graph_stage_1657917 { id="graph_stage_1657917"; isCluster="true"; label="Stage 1657917 (skipped)"; subgraph cluster_1779633 { id="cluster_1779633"; isCluster="true"; label="Exchange"; 709860 [id="node_709860" labelType="html" label="ShuffledRowRDD [709860] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779630 { id="cluster_1779630"; isCluster="true"; label="WholeStageCodegen (2)"; 709861 [id="node_709861" labelType="html" label="MapPartitionsRDD [709861] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779629 { id="cluster_1779629"; isCluster="true"; label="Exchange"; 709862 [id="node_709862" labelType="html" label="MapPartitionsRDD [709862] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 709860->709861; 709861->709862; }

709859,709860

digraph G { id="graph_1657918"; subgraph graph_stage_1657918 { id="graph_stage_1657918"; isCluster="true"; label="Stage 1657918 (skipped)"; 709902 [id="node_709902" labelType="html" label="SQLExecutionRDD [709902] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1779519 { id="cluster_1779519"; isCluster="true"; label="repartition"; 709813 [id="node_709813" labelType="html" label="ShuffledRDD [709813] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 709814 [id="node_709814" labelType="html" label="CoalescedRDD [709814] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 709815 [id="node_709815" labelType="html" label="MapPartitionsRDD [709815] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779629 { id="cluster_1779629"; isCluster="true"; label="Exchange"; 709863 [id="node_709863" labelType="html" label="ShuffledRowRDD [709863] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779628 { id="cluster_1779628"; isCluster="true"; label="InMemoryTableScan"; 709864 [id="node_709864" labelType="html" label="MapPartitionsRDD [709864] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709865 [id="node_709865" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#16691990L, 30), REPARTITION_BY_NUM, [plan_id=4963238]\n+- *(2) HashAggregate(keys=[demandChannel#16691993, shardId#16691989, kpis#16691995, version#16691991, qty#16691992, worklistShardItemId#16691990L, demandStream#16691994], functions=[], output=[shardId#16691989, worklistShardItemId#16691990L, version#16691991, qty#16691992, demandChannel#16691993, demandStream#16691994, kpis#16691995])\n +- Exchange hashpartitioning(demandChannel#16691993, shardId#16691989, kpis#16691995, version#16691991, qty#16691992, worklistShardItemId#16691990L, demandStream#16691994, 30), ENSURE_REQUIREMENTS, [plan_id=4963234]\n +- HashAggregate(keys=[demandChannel#16691993, shardId#16691989, knownfloatingpointnormalized(transform(kpis#16691995, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#16693702)) null else named_struct(label, lambda arg#16693702.label, dateTime, lambda arg#16693702.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [709865] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779716 { id="cluster_1779716"; isCluster="true"; label="InMemoryTableScan"; 709898 [id="node_709898" labelType="html" label="MapPartitionsRDD [709898] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709899 [id="node_709899" labelType="html" label="MapPartitionsRDD [709899] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 709900 [id="node_709900" labelType="html" label="MapPartitionsRDD [709900] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779715 { id="cluster_1779715"; isCluster="true"; label="DeserializeToObject"; 709901 [id="node_709901" labelType="html" label="MapPartitionsRDD [709901] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779717 { id="cluster_1779717"; isCluster="true"; label="mapPartitions"; 709903 [id="node_709903" labelType="html" label="MapPartitionsRDD [709903] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779718 { id="cluster_1779718"; isCluster="true"; label="union"; 709904 [id="node_709904" labelType="html" label="UnionRDD [709904] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779719 { id="cluster_1779719"; isCluster="true"; label="keyBy"; 709905 [id="node_709905" labelType="html" label="MapPartitionsRDD [709905] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 709813->709814; 709814->709815; 709863->709864; 709864->709865; 709865->709898; 709898->709899; 709899->709900; 709900->709901; 709901->709902; 709902->709903; 709815->709904; 709903->709904; 709904->709905; }

709812,709813

709862,709863

709815

709813

709814

709815

709904

709905

digraph G { id="graph_1657919"; subgraph graph_stage_1657919 { id="graph_stage_1657919"; isCluster="true"; label="Stage 1657919 (skipped)"; subgraph cluster_1779720 { id="cluster_1779720"; isCluster="true"; label="reduceByKey"; 709906 [id="node_709906" labelType="html" label="ShuffledRDD [709906] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779721 { id="cluster_1779721"; isCluster="true"; label="map"; 709907 [id="node_709907" labelType="html" label="MapPartitionsRDD [709907] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779722 { id="cluster_1779722"; isCluster="true"; label="repartition"; 709908 [id="node_709908" labelType="html" label="MapPartitionsRDD [709908] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 709906->709907; 709907->709908; }

709905,709906

709906

709907

709908

digraph G { id="graph_1657920"; subgraph graph_stage_1657920 { id="graph_stage_1657920"; isCluster="true"; label="Stage 1657920 (skipped)"; 710513 [id="node_710513" labelType="html" label="SQLExecutionRDD [710513] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1779722 { id="cluster_1779722"; isCluster="true"; label="repartition"; 709909 [id="node_709909" labelType="html" label="ShuffledRDD [709909] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 709910 [id="node_709910" labelType="html" label="CoalescedRDD [709910] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 709911 [id="node_709911" labelType="html" label="MapPartitionsRDD [709911] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1781289 { id="cluster_1781289"; isCluster="true"; label="map"; 710510 [id="node_710510" labelType="html" label="MapPartitionsRDD [710510] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1781291 { id="cluster_1781291"; isCluster="true"; label="WholeStageCodegen (1)"; 710511 [id="node_710511" labelType="html" label="MapPartitionsRDD [710511] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1781290 { id="cluster_1781290"; isCluster="true"; label="DeserializeToObject"; 710512 [id="node_710512" labelType="html" label="MapPartitionsRDD [710512] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1781294 { id="cluster_1781294"; isCluster="true"; label="mapPartitions"; 710514 [id="node_710514" labelType="html" label="MapPartitionsRDD [710514] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1781295 { id="cluster_1781295"; isCluster="true"; label="repartition"; 710515 [id="node_710515" labelType="html" label="MapPartitionsRDD [710515] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 709909->709910; 709910->709911; 709911->710510; 710510->710511; 710511->710512; 710512->710513; 710513->710514; 710514->710515; }

709908,709909

709911

710513

709909

709910

709911

710510

710511

710512

710514

710515

digraph G { id="graph_1657921"; subgraph graph_stage_1657921 { id="graph_stage_1657921"; isCluster="true"; label="Stage 1657921"; subgraph cluster_1781295 { id="cluster_1781295"; isCluster="true"; label="repartition"; 710516 [id="node_710516" labelType="html" label="ShuffledRDD [710516] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 710517 [id="node_710517" labelType="html" label="CoalescedRDD [710517] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 710518 [id="node_710518" labelType="html" label="MapPartitionsRDD [710518] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1781463 { id="cluster_1781463"; isCluster="true"; label="map"; 710586 [id="node_710586" labelType="html" label="MapPartitionsRDD [710586] [Cached] [Indeterminate] map at PeriodicAsyncRDDCheckpointWriterImpl.java:207}"]; } } 710516->710517; 710517->710518; 710518->710586; }

710515,710516

710518

710586

710516

710517

710518

710586

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1657921	default	count at KpiCurveCacheImpl.java:255 +details org.apache.spark.api.java.AbstractJavaRDDLike.count(JavaRDDLike.scala:46) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.logRDDCountDebug(KpiCurveCacheImpl.java:255) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.triggerCheckpointing(KpiCurveCacheImpl.java:214) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.cachelifecycle.PeriodicAsyncRDDCheckpointWriterImpl.lambda$createCheckpointsConcurrently$0(PeriodicAsyncRDDCheckpointWriterImpl.java:119) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/09/02 14:13:53	2 s	30/30	44.3 MiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1657921

default

count at KpiCurveCacheImpl.java:255 +details

org.apache.spark.api.java.AbstractJavaRDDLike.count(JavaRDDLike.scala:46)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.logRDDCountDebug(KpiCurveCacheImpl.java:255)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.triggerCheckpointing(KpiCurveCacheImpl.java:214)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.cachelifecycle.PeriodicAsyncRDDCheckpointWriterImpl.lambda$createCheckpointsConcurrently$0(PeriodicAsyncRDDCheckpointWriterImpl.java:119)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
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/09/02 14:13:53

2 s

30/30

44.3 MiB

Page:

Skipped Stages (31)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
1657920	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
1657919	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
1657918	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
1657917	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
1657916	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
1657915	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
1657914	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
1657913	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
1657912	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
1657911	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
1657910	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
1657909	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
1657908	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
1657907	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/67
1657906	default	repartition at KpiCurveCacheImpl.java:98 +details org.apache.spark.api.java.JavaRDD.repartition(JavaRDD.scala:118) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.removeShardsFromCache(KpiCurveCacheImpl.java:98) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:141) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:49) jdk.internal.reflect.GeneratedMethodAccessor620.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
1657905	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
1657904	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
1657903	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
1657902	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/67
1657901	default	repartition at KpiCurveCacheImpl.java:98 +details org.apache.spark.api.java.JavaRDD.repartition(JavaRDD.scala:118) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.removeShardsFromCache(KpiCurveCacheImpl.java:98) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:141) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:49) jdk.internal.reflect.GeneratedMethodAccessor620.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
1657900	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
1657899	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
1657898	default	repartition at KpiCurveCacheImpl.java:98 +details org.apache.spark.api.java.JavaRDD.repartition(JavaRDD.scala:118) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.microbatch.KpiCurveCacheImpl.removeShardsFromCache(KpiCurveCacheImpl.java:98) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.business.OrderQuantityOptimizationImpl.startOptimization(OrderQuantityOptimizationImpl.java:141) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.CalculateOrderProposalsForShardActivityImpl.triggerOptimize(CalculateOrderProposalsForShardActivityImpl.java:49) jdk.internal.reflect.GeneratedMethodAccessor620.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
1657897	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
1657896	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
1657895	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/67
1657894	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
1657893	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
1657892	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
1657891	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
1657890	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: