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

Status: SUCCEEDED
Submitted: 2026/09/01 14:16:48
Duration: 2 s
Associated SQL Query: 38170
Job Group: 1ebd557e-9283-4610-a07b-41d13bb785c5
Completed Stages: 1
Skipped Stages: 28

Enable zooming

digraph G { id="graph_1036581"; subgraph graph_stage_1036581 { id="graph_stage_1036581"; isCluster="true"; label="Stage 1036581 (skipped)"; 432313 [id="node_432313" labelType="html" label="SQLExecutionRDD [432313] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1083115 { id="cluster_1083115"; isCluster="true"; label="Scan parquet "; 432310 [id="node_432310" labelType="html" label="FileScanRDD [432310] start at FileStorageAdapterImpl.java:596}"]; 432311 [id="node_432311" labelType="html" label="MapPartitionsRDD [432311] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1083112 { id="cluster_1083112"; isCluster="true"; label="WholeStageCodegen (1)"; 432312 [id="node_432312" labelType="html" label="MapPartitionsRDD [432312] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1083130 { id="cluster_1083130"; isCluster="true"; label="WholeStageCodegen (1)"; 432314 [id="node_432314" labelType="html" label="MapPartitionsRDD [432314] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1083129 { id="cluster_1083129"; isCluster="true"; label="HashAggregate"; 432315 [id="node_432315" labelType="html" label="MapPartitionsRDD [432315] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1083128 { id="cluster_1083128"; isCluster="true"; label="Exchange"; 432316 [id="node_432316" labelType="html" label="MapPartitionsRDD [432316] start at FileStorageAdapterImpl.java:596}"]; } } 432310->432311; 432311->432312; 432312->432313; 432313->432314; 432314->432315; 432315->432316; }

digraph G { id="graph_1036582"; subgraph graph_stage_1036582 { id="graph_stage_1036582"; isCluster="true"; label="Stage 1036582 (skipped)"; 431389 [id="node_431389" labelType="html" label="SQLExecutionRDD [431389] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1080821 { id="cluster_1080821"; isCluster="true"; label="Scan parquet "; 431386 [id="node_431386" labelType="html" label="FileScanRDD [431386] start at FileStorageAdapterImpl.java:596}"]; 431387 [id="node_431387" labelType="html" label="MapPartitionsRDD [431387] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080818 { id="cluster_1080818"; isCluster="true"; label="WholeStageCodegen (1)"; 431388 [id="node_431388" labelType="html" label="MapPartitionsRDD [431388] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080836 { id="cluster_1080836"; isCluster="true"; label="WholeStageCodegen (1)"; 431390 [id="node_431390" labelType="html" label="MapPartitionsRDD [431390] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080835 { id="cluster_1080835"; isCluster="true"; label="HashAggregate"; 431391 [id="node_431391" labelType="html" label="MapPartitionsRDD [431391] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080834 { id="cluster_1080834"; isCluster="true"; label="Exchange"; 431392 [id="node_431392" labelType="html" label="MapPartitionsRDD [431392] start at FileStorageAdapterImpl.java:596}"]; } } 431386->431387; 431387->431388; 431388->431389; 431389->431390; 431390->431391; 431391->431392; }

digraph G { id="graph_1036583"; subgraph graph_stage_1036583 { id="graph_stage_1036583"; isCluster="true"; label="Stage 1036583 (skipped)"; 431193 [id="node_431193" labelType="html" label="SQLExecutionRDD [431193] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1079389 { id="cluster_1079389"; isCluster="true"; label="map"; 430800 [id="node_430800" labelType="html" label="MapPartitionsRDD [430800] [Cached] [Indeterminate] map at PeriodicAsyncRDDCheckpointWriterImpl.java:207}"]; } subgraph cluster_1079390 { id="cluster_1079390"; isCluster="true"; label="checkpoint"; 430801 [id="node_430801" labelType="html" label="LocalCheckpointRDD [430801] count at KpiCurveCacheImpl.java:255}"]; } subgraph cluster_1080412 { id="cluster_1080412"; isCluster="true"; label="map"; 431190 [id="node_431190" labelType="html" label="MapPartitionsRDD [431190] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080414 { id="cluster_1080414"; isCluster="true"; label="WholeStageCodegen (1)"; 431191 [id="node_431191" labelType="html" label="MapPartitionsRDD [431191] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080413 { id="cluster_1080413"; isCluster="true"; label="DeserializeToObject"; 431192 [id="node_431192" labelType="html" label="MapPartitionsRDD [431192] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080417 { id="cluster_1080417"; isCluster="true"; label="mapPartitions"; 431194 [id="node_431194" labelType="html" label="MapPartitionsRDD [431194] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080418 { id="cluster_1080418"; isCluster="true"; label="repartition"; 431195 [id="node_431195" labelType="html" label="MapPartitionsRDD [431195] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 430801->430800; 430800->431190; 431190->431191; 431191->431192; 431192->431193; 431193->431194; 431194->431195; }

430800

431193

430800

431190

431191

431192

431194

431195

digraph G { id="graph_1036584"; subgraph graph_stage_1036584 { id="graph_stage_1036584"; isCluster="true"; label="Stage 1036584 (skipped)"; 431318 [id="node_431318" labelType="html" label="SQLExecutionRDD [431318] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1080687 { id="cluster_1080687"; isCluster="true"; label="Scan parquet "; 431315 [id="node_431315" labelType="html" label="FileScanRDD [431315] start at FileStorageAdapterImpl.java:596}"]; 431316 [id="node_431316" labelType="html" label="MapPartitionsRDD [431316] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080684 { id="cluster_1080684"; isCluster="true"; label="WholeStageCodegen (1)"; 431317 [id="node_431317" labelType="html" label="MapPartitionsRDD [431317] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080702 { id="cluster_1080702"; isCluster="true"; label="WholeStageCodegen (1)"; 431319 [id="node_431319" labelType="html" label="MapPartitionsRDD [431319] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080701 { id="cluster_1080701"; isCluster="true"; label="HashAggregate"; 431320 [id="node_431320" labelType="html" label="MapPartitionsRDD [431320] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080700 { id="cluster_1080700"; isCluster="true"; label="Exchange"; 431321 [id="node_431321" labelType="html" label="MapPartitionsRDD [431321] start at FileStorageAdapterImpl.java:596}"]; } } 431315->431316; 431316->431317; 431317->431318; 431318->431319; 431319->431320; 431320->431321; }

digraph G { id="graph_1036585"; subgraph graph_stage_1036585 { id="graph_stage_1036585"; isCluster="true"; label="Stage 1036585 (skipped)"; subgraph cluster_1080700 { id="cluster_1080700"; isCluster="true"; label="Exchange"; 431322 [id="node_431322" labelType="html" label="ShuffledRowRDD [431322] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080697 { id="cluster_1080697"; isCluster="true"; label="WholeStageCodegen (2)"; 431323 [id="node_431323" labelType="html" label="MapPartitionsRDD [431323] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080696 { id="cluster_1080696"; isCluster="true"; label="Exchange"; 431324 [id="node_431324" labelType="html" label="MapPartitionsRDD [431324] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 431322->431323; 431323->431324; }

431321,431322

digraph G { id="graph_1036586"; subgraph graph_stage_1036586 { id="graph_stage_1036586"; isCluster="true"; label="Stage 1036586 (skipped)"; 431309 [id="node_431309" labelType="html" label="SQLExecutionRDD [431309] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; subgraph cluster_1080418 { id="cluster_1080418"; isCluster="true"; label="repartition"; 431196 [id="node_431196" labelType="html" label="ShuffledRDD [431196] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 431197 [id="node_431197" labelType="html" label="CoalescedRDD [431197] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 431198 [id="node_431198" labelType="html" label="MapPartitionsRDD [431198] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080644 { id="cluster_1080644"; isCluster="true"; label="map"; 431306 [id="node_431306" labelType="html" label="MapPartitionsRDD [431306] [Indeterminate] createDataFrame at KpiCurveCacheImpl.java:230}"]; } subgraph cluster_1080646 { id="cluster_1080646"; isCluster="true"; label="WholeStageCodegen (1)"; 431307 [id="node_431307" labelType="html" label="MapPartitionsRDD [431307] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1080645 { id="cluster_1080645"; isCluster="true"; label="DeserializeToObject"; 431308 [id="node_431308" labelType="html" label="MapPartitionsRDD [431308] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1080649 { id="cluster_1080649"; isCluster="true"; label="mapPartitions"; 431310 [id="node_431310" labelType="html" label="MapPartitionsRDD [431310] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1080650 { id="cluster_1080650"; isCluster="true"; label="repartition"; 431311 [id="node_431311" labelType="html" label="MapPartitionsRDD [431311] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } } 431196->431197; 431197->431198; 431198->431306; 431306->431307; 431307->431308; 431308->431309; 431309->431310; 431310->431311; }

431195,431196

431198

431309

431196

431197

431198

431306

431307

431308

431310

431311

digraph G { id="graph_1036587"; subgraph graph_stage_1036587 { id="graph_stage_1036587"; isCluster="true"; label="Stage 1036587 (skipped)"; 431363 [id="node_431363" labelType="html" label="SQLExecutionRDD [431363] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1080650 { id="cluster_1080650"; isCluster="true"; label="repartition"; 431312 [id="node_431312" labelType="html" label="ShuffledRDD [431312] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 431313 [id="node_431313" labelType="html" label="CoalescedRDD [431313] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 431314 [id="node_431314" labelType="html" label="MapPartitionsRDD [431314] [Cached] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } subgraph cluster_1080696 { id="cluster_1080696"; isCluster="true"; label="Exchange"; 431325 [id="node_431325" labelType="html" label="ShuffledRowRDD [431325] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080695 { id="cluster_1080695"; isCluster="true"; label="InMemoryTableScan"; 431326 [id="node_431326" labelType="html" label="MapPartitionsRDD [431326] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 431327 [id="node_431327" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#9675734L, 30), REPARTITION_BY_NUM, [plan_id=3001285]\n+- *(2) HashAggregate(keys=[demandChannel#9675737, shardId#9675733, kpis#9675739, version#9675735, qty#9675736, worklistShardItemId#9675734L, demandStream#9675738], functions=[], output=[shardId#9675733, worklistShardItemId#9675734L, version#9675735, qty#9675736, demandChannel#9675737, demandStream#9675738, kpis#9675739])\n +- Exchange hashpartitioning(demandChannel#9675737, shardId#9675733, kpis#9675739, version#9675735, qty#9675736, worklistShardItemId#9675734L, demandStream#9675738, 30), ENSURE_REQUIREMENTS, [plan_id=3001281]\n +- HashAggregate(keys=[demandChannel#9675737, shardId#9675733, knownfloatingpointnormalized(transform(kpis#9675739, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#10140522)) null else named_struct(label, lambda arg#10140522.label, dateTime, lambda arg#10140522.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#10140522.value)))), lam... [431327] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080785 { id="cluster_1080785"; isCluster="true"; label="InMemoryTableScan"; 431359 [id="node_431359" labelType="html" label="MapPartitionsRDD [431359] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 431360 [id="node_431360" labelType="html" label="MapPartitionsRDD [431360] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 431361 [id="node_431361" labelType="html" label="MapPartitionsRDD [431361] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080784 { id="cluster_1080784"; isCluster="true"; label="DeserializeToObject"; 431362 [id="node_431362" labelType="html" label="MapPartitionsRDD [431362] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080786 { id="cluster_1080786"; isCluster="true"; label="mapPartitions"; 431364 [id="node_431364" labelType="html" label="MapPartitionsRDD [431364] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080787 { id="cluster_1080787"; isCluster="true"; label="union"; 431365 [id="node_431365" labelType="html" label="UnionRDD [431365] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080788 { id="cluster_1080788"; isCluster="true"; label="keyBy"; 431366 [id="node_431366" labelType="html" label="MapPartitionsRDD [431366] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 431312->431313; 431313->431314; 431325->431326; 431326->431327; 431327->431359; 431359->431360; 431360->431361; 431361->431362; 431362->431363; 431363->431364; 431314->431365; 431364->431365; 431365->431366; }

431311,431312

431324,431325

431314

431312

431313

431314

431365

431366

digraph G { id="graph_1036588"; subgraph graph_stage_1036588 { id="graph_stage_1036588"; isCluster="true"; label="Stage 1036588 (skipped)"; subgraph cluster_1080789 { id="cluster_1080789"; isCluster="true"; label="reduceByKey"; 431367 [id="node_431367" labelType="html" label="ShuffledRDD [431367] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080790 { id="cluster_1080790"; isCluster="true"; label="map"; 431368 [id="node_431368" labelType="html" label="MapPartitionsRDD [431368] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080791 { id="cluster_1080791"; isCluster="true"; label="repartition"; 431369 [id="node_431369" labelType="html" label="MapPartitionsRDD [431369] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 431367->431368; 431368->431369; }

431366,431367

431367

431368

431369

digraph G { id="graph_1036589"; subgraph graph_stage_1036589 { id="graph_stage_1036589"; isCluster="true"; label="Stage 1036589 (skipped)"; subgraph cluster_1080834 { id="cluster_1080834"; isCluster="true"; label="Exchange"; 431393 [id="node_431393" labelType="html" label="ShuffledRowRDD [431393] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080831 { id="cluster_1080831"; isCluster="true"; label="WholeStageCodegen (2)"; 431394 [id="node_431394" labelType="html" label="MapPartitionsRDD [431394] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080830 { id="cluster_1080830"; isCluster="true"; label="Exchange"; 431395 [id="node_431395" labelType="html" label="MapPartitionsRDD [431395] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 431393->431394; 431394->431395; }

431392,431393

digraph G { id="graph_1036590"; subgraph graph_stage_1036590 { id="graph_stage_1036590"; isCluster="true"; label="Stage 1036590 (skipped)"; 431449 [id="node_431449" labelType="html" label="SQLExecutionRDD [431449] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1080791 { id="cluster_1080791"; isCluster="true"; label="repartition"; 431370 [id="node_431370" labelType="html" label="ShuffledRDD [431370] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 431371 [id="node_431371" labelType="html" label="CoalescedRDD [431371] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 431372 [id="node_431372" labelType="html" label="MapPartitionsRDD [431372] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080830 { id="cluster_1080830"; isCluster="true"; label="Exchange"; 431396 [id="node_431396" labelType="html" label="ShuffledRowRDD [431396] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080829 { id="cluster_1080829"; isCluster="true"; label="InMemoryTableScan"; 431397 [id="node_431397" labelType="html" label="MapPartitionsRDD [431397] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 431398 [id="node_431398" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#10142168L, 30), REPARTITION_BY_NUM, [plan_id=3001601]\n+- *(2) HashAggregate(keys=[demandChannel#10142171, shardId#10142167, kpis#10142173, version#10142169, qty#10142170, worklistShardItemId#10142168L, demandStream#10142172], functions=[], output=[shardId#10142167, worklistShardItemId#10142168L, version#10142169, qty#10142170, demandChannel#10142171, demandStream#10142172, kpis#10142173])\n +- Exchange hashpartitioning(demandChannel#10142171, shardId#10142167, kpis#10142173, version#10142169, qty#10142170, worklistShardItemId#10142168L, demandStream#10142172, 30), ENSURE_REQUIREMENTS, [plan_id=3001597]\n +- HashAggregate(keys=[demandChannel#10142171, shardId#10142167, knownfloatingpointnormalized(transform(kpis#10142173, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#10143160)) null else named_struct(label, lambda arg#10143160.label, dateTime, lambda arg#10143160.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda ar... [431398] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080959 { id="cluster_1080959"; isCluster="true"; label="InMemoryTableScan"; 431445 [id="node_431445" labelType="html" label="MapPartitionsRDD [431445] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 431446 [id="node_431446" labelType="html" label="MapPartitionsRDD [431446] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 431447 [id="node_431447" labelType="html" label="MapPartitionsRDD [431447] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080958 { id="cluster_1080958"; isCluster="true"; label="DeserializeToObject"; 431448 [id="node_431448" labelType="html" label="MapPartitionsRDD [431448] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080960 { id="cluster_1080960"; isCluster="true"; label="mapPartitions"; 431450 [id="node_431450" labelType="html" label="MapPartitionsRDD [431450] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080961 { id="cluster_1080961"; isCluster="true"; label="union"; 431451 [id="node_431451" labelType="html" label="UnionRDD [431451] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080962 { id="cluster_1080962"; isCluster="true"; label="keyBy"; 431452 [id="node_431452" labelType="html" label="MapPartitionsRDD [431452] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 431370->431371; 431371->431372; 431396->431397; 431397->431398; 431398->431445; 431445->431446; 431446->431447; 431447->431448; 431448->431449; 431449->431450; 431372->431451; 431450->431451; 431451->431452; }

431369,431370

431395,431396

431372

431370

431371

431372

431451

431452

digraph G { id="graph_1036591"; subgraph graph_stage_1036591 { id="graph_stage_1036591"; isCluster="true"; label="Stage 1036591 (skipped)"; subgraph cluster_1080963 { id="cluster_1080963"; isCluster="true"; label="reduceByKey"; 431453 [id="node_431453" labelType="html" label="ShuffledRDD [431453] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080964 { id="cluster_1080964"; isCluster="true"; label="map"; 431454 [id="node_431454" labelType="html" label="MapPartitionsRDD [431454] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1080965 { id="cluster_1080965"; isCluster="true"; label="repartition"; 431455 [id="node_431455" labelType="html" label="MapPartitionsRDD [431455] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 431453->431454; 431454->431455; }

431452,431453

431453

431454

431455

digraph G { id="graph_1036592"; subgraph graph_stage_1036592 { id="graph_stage_1036592"; isCluster="true"; label="Stage 1036592 (skipped)"; 432188 [id="node_432188" labelType="html" label="SQLExecutionRDD [432188] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1080965 { id="cluster_1080965"; isCluster="true"; label="repartition"; 431456 [id="node_431456" labelType="html" label="ShuffledRDD [431456] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 431457 [id="node_431457" labelType="html" label="CoalescedRDD [431457] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 431458 [id="node_431458" labelType="html" label="MapPartitionsRDD [431458] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1082854 { id="cluster_1082854"; isCluster="true"; label="map"; 432185 [id="node_432185" labelType="html" label="MapPartitionsRDD [432185] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1082856 { id="cluster_1082856"; isCluster="true"; label="WholeStageCodegen (1)"; 432186 [id="node_432186" labelType="html" label="MapPartitionsRDD [432186] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1082855 { id="cluster_1082855"; isCluster="true"; label="DeserializeToObject"; 432187 [id="node_432187" labelType="html" label="MapPartitionsRDD [432187] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1082859 { id="cluster_1082859"; isCluster="true"; label="mapPartitions"; 432189 [id="node_432189" labelType="html" label="MapPartitionsRDD [432189] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1082860 { id="cluster_1082860"; isCluster="true"; label="repartition"; 432190 [id="node_432190" labelType="html" label="MapPartitionsRDD [432190] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 431456->431457; 431457->431458; 431458->432185; 432185->432186; 432186->432187; 432187->432188; 432188->432189; 432189->432190; }

431455,431456

431458

432188

431456

431457

431458

432185

432186

432187

432189

432190

digraph G { id="graph_1036593"; subgraph graph_stage_1036593 { id="graph_stage_1036593"; isCluster="true"; label="Stage 1036593 (skipped)"; 432304 [id="node_432304" labelType="html" label="SQLExecutionRDD [432304] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; subgraph cluster_1082860 { id="cluster_1082860"; isCluster="true"; label="repartition"; 432191 [id="node_432191" labelType="html" label="ShuffledRDD [432191] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 432192 [id="node_432192" labelType="html" label="CoalescedRDD [432192] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 432193 [id="node_432193" labelType="html" label="MapPartitionsRDD [432193] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1083082 { id="cluster_1083082"; isCluster="true"; label="map"; 432301 [id="node_432301" labelType="html" label="MapPartitionsRDD [432301] [Indeterminate] createDataFrame at KpiCurveCacheImpl.java:230}"]; } subgraph cluster_1083084 { id="cluster_1083084"; isCluster="true"; label="WholeStageCodegen (1)"; 432302 [id="node_432302" labelType="html" label="MapPartitionsRDD [432302] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1083083 { id="cluster_1083083"; isCluster="true"; label="DeserializeToObject"; 432303 [id="node_432303" labelType="html" label="MapPartitionsRDD [432303] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1083087 { id="cluster_1083087"; isCluster="true"; label="mapPartitions"; 432305 [id="node_432305" labelType="html" label="MapPartitionsRDD [432305] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1083088 { id="cluster_1083088"; isCluster="true"; label="repartition"; 432306 [id="node_432306" labelType="html" label="MapPartitionsRDD [432306] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } } 432191->432192; 432192->432193; 432193->432301; 432301->432302; 432302->432303; 432303->432304; 432304->432305; 432305->432306; }

432190,432191

432193

432304

432191

432192

432193

432301

432302

432303

432305

432306

digraph G { id="graph_1036594"; subgraph graph_stage_1036594 { id="graph_stage_1036594"; isCluster="true"; label="Stage 1036594 (skipped)"; subgraph cluster_1083128 { id="cluster_1083128"; isCluster="true"; label="Exchange"; 432317 [id="node_432317" labelType="html" label="ShuffledRowRDD [432317] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1083125 { id="cluster_1083125"; isCluster="true"; label="WholeStageCodegen (2)"; 432318 [id="node_432318" labelType="html" label="MapPartitionsRDD [432318] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1083124 { id="cluster_1083124"; isCluster="true"; label="Exchange"; 432319 [id="node_432319" labelType="html" label="MapPartitionsRDD [432319] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 432317->432318; 432318->432319; }

432316,432317

digraph G { id="graph_1036595"; subgraph graph_stage_1036595 { id="graph_stage_1036595"; isCluster="true"; label="Stage 1036595 (skipped)"; 432335 [id="node_432335" labelType="html" label="SQLExecutionRDD [432335] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1083088 { id="cluster_1083088"; isCluster="true"; label="repartition"; 432307 [id="node_432307" labelType="html" label="ShuffledRDD [432307] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 432308 [id="node_432308" labelType="html" label="CoalescedRDD [432308] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 432309 [id="node_432309" labelType="html" label="MapPartitionsRDD [432309] [Cached] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } subgraph cluster_1083124 { id="cluster_1083124"; isCluster="true"; label="Exchange"; 432320 [id="node_432320" labelType="html" label="ShuffledRowRDD [432320] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1083123 { id="cluster_1083123"; isCluster="true"; label="InMemoryTableScan"; 432321 [id="node_432321" labelType="html" label="MapPartitionsRDD [432321] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 432322 [id="node_432322" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#9675734L, 30), REPARTITION_BY_NUM, [plan_id=3007136]\n+- *(2) HashAggregate(keys=[demandChannel#9675737, shardId#9675733, kpis#9675739, version#9675735, qty#9675736, worklistShardItemId#9675734L, demandStream#9675738], functions=[], output=[shardId#9675733, worklistShardItemId#9675734L, version#9675735, qty#9675736, demandChannel#9675737, demandStream#9675738, kpis#9675739])\n +- Exchange hashpartitioning(demandChannel#9675737, shardId#9675733, kpis#9675739, version#9675735, qty#9675736, worklistShardItemId#9675734L, demandStream#9675738, 30), ENSURE_REQUIREMENTS, [plan_id=3007132]\n +- HashAggregate(keys=[demandChannel#9675737, shardId#9675733, knownfloatingpointnormalized(transform(kpis#9675739, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#10163142)) null else named_struct(label, lambda arg#10163142.label, dateTime, lambda arg#10163142.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#10163142.value)))), lam... [432322] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1083166 { id="cluster_1083166"; isCluster="true"; label="InMemoryTableScan"; 432331 [id="node_432331" labelType="html" label="MapPartitionsRDD [432331] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 432332 [id="node_432332" labelType="html" label="MapPartitionsRDD [432332] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 432333 [id="node_432333" labelType="html" label="MapPartitionsRDD [432333] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1083165 { id="cluster_1083165"; isCluster="true"; label="DeserializeToObject"; 432334 [id="node_432334" labelType="html" label="MapPartitionsRDD [432334] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1083167 { id="cluster_1083167"; isCluster="true"; label="mapPartitions"; 432336 [id="node_432336" labelType="html" label="MapPartitionsRDD [432336] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1083168 { id="cluster_1083168"; isCluster="true"; label="union"; 432337 [id="node_432337" labelType="html" label="UnionRDD [432337] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1083169 { id="cluster_1083169"; isCluster="true"; label="keyBy"; 432338 [id="node_432338" labelType="html" label="MapPartitionsRDD [432338] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 432307->432308; 432308->432309; 432320->432321; 432321->432322; 432322->432331; 432331->432332; 432332->432333; 432333->432334; 432334->432335; 432335->432336; 432309->432337; 432336->432337; 432337->432338; }

432306,432307

432319,432320

432309

432307

432308

432309

432337

432338

digraph G { id="graph_1036596"; subgraph graph_stage_1036596 { id="graph_stage_1036596"; isCluster="true"; label="Stage 1036596 (skipped)"; subgraph cluster_1083170 { id="cluster_1083170"; isCluster="true"; label="reduceByKey"; 432339 [id="node_432339" labelType="html" label="ShuffledRDD [432339] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1083171 { id="cluster_1083171"; isCluster="true"; label="map"; 432340 [id="node_432340" labelType="html" label="MapPartitionsRDD [432340] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1083172 { id="cluster_1083172"; isCluster="true"; label="repartition"; 432341 [id="node_432341" labelType="html" label="MapPartitionsRDD [432341] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 432339->432340; 432340->432341; }

432338,432339

432339

432340

432341

digraph G { id="graph_1036597"; subgraph graph_stage_1036597 { id="graph_stage_1036597"; isCluster="true"; label="Stage 1036597 (skipped)"; 433079 [id="node_433079" labelType="html" label="SQLExecutionRDD [433079] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1083172 { id="cluster_1083172"; isCluster="true"; label="repartition"; 432342 [id="node_432342" labelType="html" label="ShuffledRDD [432342] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 432343 [id="node_432343" labelType="html" label="CoalescedRDD [432343] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 432344 [id="node_432344" labelType="html" label="MapPartitionsRDD [432344] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085082 { id="cluster_1085082"; isCluster="true"; label="map"; 433076 [id="node_433076" labelType="html" label="MapPartitionsRDD [433076] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085084 { id="cluster_1085084"; isCluster="true"; label="WholeStageCodegen (1)"; 433077 [id="node_433077" labelType="html" label="MapPartitionsRDD [433077] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085083 { id="cluster_1085083"; isCluster="true"; label="DeserializeToObject"; 433078 [id="node_433078" labelType="html" label="MapPartitionsRDD [433078] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085087 { id="cluster_1085087"; isCluster="true"; label="mapPartitions"; 433080 [id="node_433080" labelType="html" label="MapPartitionsRDD [433080] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085088 { id="cluster_1085088"; isCluster="true"; label="repartition"; 433081 [id="node_433081" labelType="html" label="MapPartitionsRDD [433081] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 432342->432343; 432343->432344; 432344->433076; 433076->433077; 433077->433078; 433078->433079; 433079->433080; 433080->433081; }

432341,432342

432344

433079

432342

432343

432344

433076

433077

433078

433080

433081

digraph G { id="graph_1036598"; subgraph graph_stage_1036598 { id="graph_stage_1036598"; isCluster="true"; label="Stage 1036598 (skipped)"; 433204 [id="node_433204" labelType="html" label="SQLExecutionRDD [433204] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1085343 { id="cluster_1085343"; isCluster="true"; label="Scan parquet "; 433201 [id="node_433201" labelType="html" label="FileScanRDD [433201] start at FileStorageAdapterImpl.java:596}"]; 433202 [id="node_433202" labelType="html" label="MapPartitionsRDD [433202] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085340 { id="cluster_1085340"; isCluster="true"; label="WholeStageCodegen (1)"; 433203 [id="node_433203" labelType="html" label="MapPartitionsRDD [433203] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085358 { id="cluster_1085358"; isCluster="true"; label="WholeStageCodegen (1)"; 433205 [id="node_433205" labelType="html" label="MapPartitionsRDD [433205] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085357 { id="cluster_1085357"; isCluster="true"; label="HashAggregate"; 433206 [id="node_433206" labelType="html" label="MapPartitionsRDD [433206] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085356 { id="cluster_1085356"; isCluster="true"; label="Exchange"; 433207 [id="node_433207" labelType="html" label="MapPartitionsRDD [433207] start at FileStorageAdapterImpl.java:596}"]; } } 433201->433202; 433202->433203; 433203->433204; 433204->433205; 433205->433206; 433206->433207; }

digraph G { id="graph_1036599"; subgraph graph_stage_1036599 { id="graph_stage_1036599"; isCluster="true"; label="Stage 1036599 (skipped)"; subgraph cluster_1085356 { id="cluster_1085356"; isCluster="true"; label="Exchange"; 433208 [id="node_433208" labelType="html" label="ShuffledRowRDD [433208] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085353 { id="cluster_1085353"; isCluster="true"; label="WholeStageCodegen (2)"; 433209 [id="node_433209" labelType="html" label="MapPartitionsRDD [433209] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085352 { id="cluster_1085352"; isCluster="true"; label="Exchange"; 433210 [id="node_433210" labelType="html" label="MapPartitionsRDD [433210] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 433208->433209; 433209->433210; }

433207,433208

digraph G { id="graph_1036600"; subgraph graph_stage_1036600 { id="graph_stage_1036600"; isCluster="true"; label="Stage 1036600 (skipped)"; 433195 [id="node_433195" labelType="html" label="SQLExecutionRDD [433195] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; subgraph cluster_1085088 { id="cluster_1085088"; isCluster="true"; label="repartition"; 433082 [id="node_433082" labelType="html" label="ShuffledRDD [433082] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 433083 [id="node_433083" labelType="html" label="CoalescedRDD [433083] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 433084 [id="node_433084" labelType="html" label="MapPartitionsRDD [433084] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085333 { id="cluster_1085333"; isCluster="true"; label="map"; 433192 [id="node_433192" labelType="html" label="MapPartitionsRDD [433192] [Indeterminate] createDataFrame at KpiCurveCacheImpl.java:230}"]; } subgraph cluster_1085335 { id="cluster_1085335"; isCluster="true"; label="WholeStageCodegen (1)"; 433193 [id="node_433193" labelType="html" label="MapPartitionsRDD [433193] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1085334 { id="cluster_1085334"; isCluster="true"; label="DeserializeToObject"; 433194 [id="node_433194" labelType="html" label="MapPartitionsRDD [433194] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1085338 { id="cluster_1085338"; isCluster="true"; label="mapPartitions"; 433196 [id="node_433196" labelType="html" label="MapPartitionsRDD [433196] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1085339 { id="cluster_1085339"; isCluster="true"; label="repartition"; 433197 [id="node_433197" labelType="html" label="MapPartitionsRDD [433197] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } } 433082->433083; 433083->433084; 433084->433192; 433192->433193; 433193->433194; 433194->433195; 433195->433196; 433196->433197; }

433081,433082

433084

433195

433082

433083

433084

433192

433193

433194

433196

433197

digraph G { id="graph_1036601"; subgraph graph_stage_1036601 { id="graph_stage_1036601"; isCluster="true"; label="Stage 1036601 (skipped)"; 433234 [id="node_433234" labelType="html" label="SQLExecutionRDD [433234] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1085339 { id="cluster_1085339"; isCluster="true"; label="repartition"; 433198 [id="node_433198" labelType="html" label="ShuffledRDD [433198] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 433199 [id="node_433199" labelType="html" label="CoalescedRDD [433199] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 433200 [id="node_433200" labelType="html" label="MapPartitionsRDD [433200] [Cached] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } subgraph cluster_1085352 { id="cluster_1085352"; isCluster="true"; label="Exchange"; 433211 [id="node_433211" labelType="html" label="ShuffledRowRDD [433211] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085351 { id="cluster_1085351"; isCluster="true"; label="InMemoryTableScan"; 433212 [id="node_433212" labelType="html" label="MapPartitionsRDD [433212] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 433213 [id="node_433213" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#9675734L, 30), REPARTITION_BY_NUM, [plan_id=3012520]\n+- *(2) HashAggregate(keys=[demandChannel#9675737, shardId#9675733, kpis#9675739, version#9675735, qty#9675736, worklistShardItemId#9675734L, demandStream#9675738], functions=[], output=[shardId#9675733, worklistShardItemId#9675734L, version#9675735, qty#9675736, demandChannel#9675737, demandStream#9675738, kpis#9675739])\n +- Exchange hashpartitioning(demandChannel#9675737, shardId#9675733, kpis#9675739, version#9675735, qty#9675736, worklistShardItemId#9675734L, demandStream#9675738, 30), ENSURE_REQUIREMENTS, [plan_id=3012516]\n +- HashAggregate(keys=[demandChannel#9675737, shardId#9675733, knownfloatingpointnormalized(transform(kpis#9675739, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#10184534)) null else named_struct(label, lambda arg#10184534.label, dateTime, lambda arg#10184534.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#10184534.value)))), lam... [433213] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085413 { id="cluster_1085413"; isCluster="true"; label="InMemoryTableScan"; 433230 [id="node_433230" labelType="html" label="MapPartitionsRDD [433230] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 433231 [id="node_433231" labelType="html" label="MapPartitionsRDD [433231] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 433232 [id="node_433232" labelType="html" label="MapPartitionsRDD [433232] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085412 { id="cluster_1085412"; isCluster="true"; label="DeserializeToObject"; 433233 [id="node_433233" labelType="html" label="MapPartitionsRDD [433233] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085414 { id="cluster_1085414"; isCluster="true"; label="mapPartitions"; 433235 [id="node_433235" labelType="html" label="MapPartitionsRDD [433235] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085415 { id="cluster_1085415"; isCluster="true"; label="union"; 433236 [id="node_433236" labelType="html" label="UnionRDD [433236] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085416 { id="cluster_1085416"; isCluster="true"; label="keyBy"; 433237 [id="node_433237" labelType="html" label="MapPartitionsRDD [433237] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 433198->433199; 433199->433200; 433211->433212; 433212->433213; 433213->433230; 433230->433231; 433231->433232; 433232->433233; 433233->433234; 433234->433235; 433200->433236; 433235->433236; 433236->433237; }

433197,433198

433210,433211

433200

433198

433199

433200

433236

433237

digraph G { id="graph_1036602"; subgraph graph_stage_1036602 { id="graph_stage_1036602"; isCluster="true"; label="Stage 1036602 (skipped)"; subgraph cluster_1085417 { id="cluster_1085417"; isCluster="true"; label="reduceByKey"; 433238 [id="node_433238" labelType="html" label="ShuffledRDD [433238] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085418 { id="cluster_1085418"; isCluster="true"; label="map"; 433239 [id="node_433239" labelType="html" label="MapPartitionsRDD [433239] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085419 { id="cluster_1085419"; isCluster="true"; label="repartition"; 433240 [id="node_433240" labelType="html" label="MapPartitionsRDD [433240] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 433238->433239; 433239->433240; }

433237,433238

433238

433239

433240

digraph G { id="graph_1036603"; subgraph graph_stage_1036603 { id="graph_stage_1036603"; isCluster="true"; label="Stage 1036603 (skipped)"; 433942 [id="node_433942" labelType="html" label="SQLExecutionRDD [433942] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1085419 { id="cluster_1085419"; isCluster="true"; label="repartition"; 433241 [id="node_433241" labelType="html" label="ShuffledRDD [433241] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 433242 [id="node_433242" labelType="html" label="CoalescedRDD [433242] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 433243 [id="node_433243" labelType="html" label="MapPartitionsRDD [433243] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087230 { id="cluster_1087230"; isCluster="true"; label="map"; 433939 [id="node_433939" labelType="html" label="MapPartitionsRDD [433939] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087232 { id="cluster_1087232"; isCluster="true"; label="WholeStageCodegen (1)"; 433940 [id="node_433940" labelType="html" label="MapPartitionsRDD [433940] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087231 { id="cluster_1087231"; isCluster="true"; label="DeserializeToObject"; 433941 [id="node_433941" labelType="html" label="MapPartitionsRDD [433941] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087235 { id="cluster_1087235"; isCluster="true"; label="mapPartitions"; 433943 [id="node_433943" labelType="html" label="MapPartitionsRDD [433943] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087236 { id="cluster_1087236"; isCluster="true"; label="repartition"; 433944 [id="node_433944" labelType="html" label="MapPartitionsRDD [433944] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 433241->433242; 433242->433243; 433243->433939; 433939->433940; 433940->433941; 433941->433942; 433942->433943; 433943->433944; }

433240,433241

433243

433942

433241

433242

433243

433939

433940

433941

433943

433944

digraph G { id="graph_1036604"; subgraph graph_stage_1036604 { id="graph_stage_1036604"; isCluster="true"; label="Stage 1036604 (skipped)"; 434067 [id="node_434067" labelType="html" label="SQLExecutionRDD [434067] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1087491 { id="cluster_1087491"; isCluster="true"; label="Scan parquet "; 434064 [id="node_434064" labelType="html" label="FileScanRDD [434064] start at FileStorageAdapterImpl.java:596}"]; 434065 [id="node_434065" labelType="html" label="MapPartitionsRDD [434065] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087488 { id="cluster_1087488"; isCluster="true"; label="WholeStageCodegen (1)"; 434066 [id="node_434066" labelType="html" label="MapPartitionsRDD [434066] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087506 { id="cluster_1087506"; isCluster="true"; label="WholeStageCodegen (1)"; 434068 [id="node_434068" labelType="html" label="MapPartitionsRDD [434068] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087505 { id="cluster_1087505"; isCluster="true"; label="HashAggregate"; 434069 [id="node_434069" labelType="html" label="MapPartitionsRDD [434069] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087504 { id="cluster_1087504"; isCluster="true"; label="Exchange"; 434070 [id="node_434070" labelType="html" label="MapPartitionsRDD [434070] start at FileStorageAdapterImpl.java:596}"]; } } 434064->434065; 434065->434066; 434066->434067; 434067->434068; 434068->434069; 434069->434070; }

digraph G { id="graph_1036605"; subgraph graph_stage_1036605 { id="graph_stage_1036605"; isCluster="true"; label="Stage 1036605 (skipped)"; subgraph cluster_1087504 { id="cluster_1087504"; isCluster="true"; label="Exchange"; 434071 [id="node_434071" labelType="html" label="ShuffledRowRDD [434071] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087501 { id="cluster_1087501"; isCluster="true"; label="WholeStageCodegen (2)"; 434072 [id="node_434072" labelType="html" label="MapPartitionsRDD [434072] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087500 { id="cluster_1087500"; isCluster="true"; label="Exchange"; 434073 [id="node_434073" labelType="html" label="MapPartitionsRDD [434073] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } } 434071->434072; 434072->434073; }

434070,434071

digraph G { id="graph_1036606"; subgraph graph_stage_1036606 { id="graph_stage_1036606"; isCluster="true"; label="Stage 1036606 (skipped)"; 434058 [id="node_434058" labelType="html" label="SQLExecutionRDD [434058] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; subgraph cluster_1087236 { id="cluster_1087236"; isCluster="true"; label="repartition"; 433945 [id="node_433945" labelType="html" label="ShuffledRDD [433945] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 433946 [id="node_433946" labelType="html" label="CoalescedRDD [433946] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 433947 [id="node_433947" labelType="html" label="MapPartitionsRDD [433947] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087458 { id="cluster_1087458"; isCluster="true"; label="map"; 434055 [id="node_434055" labelType="html" label="MapPartitionsRDD [434055] [Indeterminate] createDataFrame at KpiCurveCacheImpl.java:230}"]; } subgraph cluster_1087483 { id="cluster_1087483"; isCluster="true"; label="WholeStageCodegen (1)"; 434056 [id="node_434056" labelType="html" label="MapPartitionsRDD [434056] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1087482 { id="cluster_1087482"; isCluster="true"; label="DeserializeToObject"; 434057 [id="node_434057" labelType="html" label="MapPartitionsRDD [434057] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1087486 { id="cluster_1087486"; isCluster="true"; label="mapPartitions"; 434059 [id="node_434059" labelType="html" label="MapPartitionsRDD [434059] [Indeterminate] javaRDD at KpiCurveCacheImpl.java:97}"]; } subgraph cluster_1087487 { id="cluster_1087487"; isCluster="true"; label="repartition"; 434060 [id="node_434060" labelType="html" label="MapPartitionsRDD [434060] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } } 433945->433946; 433946->433947; 433947->434055; 434055->434056; 434056->434057; 434057->434058; 434058->434059; 434059->434060; }

433944,433945

433947

434058

433945

433946

433947

434055

434056

434057

434059

434060

digraph G { id="graph_1036607"; subgraph graph_stage_1036607 { id="graph_stage_1036607"; isCluster="true"; label="Stage 1036607 (skipped)"; 434089 [id="node_434089" labelType="html" label="SQLExecutionRDD [434089] [Unordered] start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1087487 { id="cluster_1087487"; isCluster="true"; label="repartition"; 434061 [id="node_434061" labelType="html" label="ShuffledRDD [434061] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 434062 [id="node_434062" labelType="html" label="CoalescedRDD [434062] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; 434063 [id="node_434063" labelType="html" label="MapPartitionsRDD [434063] [Cached] [Indeterminate] repartition at KpiCurveCacheImpl.java:98}"]; } subgraph cluster_1087500 { id="cluster_1087500"; isCluster="true"; label="Exchange"; 434074 [id="node_434074" labelType="html" label="ShuffledRowRDD [434074] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087499 { id="cluster_1087499"; isCluster="true"; label="InMemoryTableScan"; 434075 [id="node_434075" labelType="html" label="MapPartitionsRDD [434075] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 434076 [id="node_434076" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#9675734L, 30), REPARTITION_BY_NUM, [plan_id=3017737]\n+- *(2) HashAggregate(keys=[demandChannel#9675737, shardId#9675733, kpis#9675739, version#9675735, qty#9675736, worklistShardItemId#9675734L, demandStream#9675738], functions=[], output=[shardId#9675733, worklistShardItemId#9675734L, version#9675735, qty#9675736, demandChannel#9675737, demandStream#9675738, kpis#9675739])\n +- Exchange hashpartitioning(demandChannel#9675737, shardId#9675733, kpis#9675739, version#9675735, qty#9675736, worklistShardItemId#9675734L, demandStream#9675738, 30), ENSURE_REQUIREMENTS, [plan_id=3017733]\n +- HashAggregate(keys=[demandChannel#9675737, shardId#9675733, knownfloatingpointnormalized(transform(kpis#9675739, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#10205592)) null else named_struct(label, lambda arg#10205592.label, dateTime, lambda arg#10205592.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#10205592.value)))), lam... [434076] [Cached] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087542 { id="cluster_1087542"; isCluster="true"; label="InMemoryTableScan"; 434085 [id="node_434085" labelType="html" label="MapPartitionsRDD [434085] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 434086 [id="node_434086" labelType="html" label="MapPartitionsRDD [434086] [Unordered] start at FileStorageAdapterImpl.java:596}"]; 434087 [id="node_434087" labelType="html" label="MapPartitionsRDD [434087] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087541 { id="cluster_1087541"; isCluster="true"; label="DeserializeToObject"; 434088 [id="node_434088" labelType="html" label="MapPartitionsRDD [434088] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087543 { id="cluster_1087543"; isCluster="true"; label="mapPartitions"; 434090 [id="node_434090" labelType="html" label="MapPartitionsRDD [434090] [Unordered] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087544 { id="cluster_1087544"; isCluster="true"; label="union"; 434091 [id="node_434091" labelType="html" label="UnionRDD [434091] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087545 { id="cluster_1087545"; isCluster="true"; label="keyBy"; 434092 [id="node_434092" labelType="html" label="MapPartitionsRDD [434092] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 434061->434062; 434062->434063; 434074->434075; 434075->434076; 434076->434085; 434085->434086; 434086->434087; 434087->434088; 434088->434089; 434089->434090; 434063->434091; 434090->434091; 434091->434092; }

434060,434061

434073,434074

434063

434076

434061

434062

434063

434091

434092

digraph G { id="graph_1036608"; subgraph graph_stage_1036608 { id="graph_stage_1036608"; isCluster="true"; label="Stage 1036608 (skipped)"; subgraph cluster_1087546 { id="cluster_1087546"; isCluster="true"; label="reduceByKey"; 434093 [id="node_434093" labelType="html" label="ShuffledRDD [434093] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087547 { id="cluster_1087547"; isCluster="true"; label="map"; 434094 [id="node_434094" labelType="html" label="MapPartitionsRDD [434094] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087548 { id="cluster_1087548"; isCluster="true"; label="repartition"; 434095 [id="node_434095" labelType="html" label="MapPartitionsRDD [434095] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 434093->434094; 434094->434095; }

434092,434093

434093

434094

434095

digraph G { id="graph_1036609"; subgraph graph_stage_1036609 { id="graph_stage_1036609"; isCluster="true"; label="Stage 1036609"; subgraph cluster_1087548 { id="cluster_1087548"; isCluster="true"; label="repartition"; 434096 [id="node_434096" labelType="html" label="ShuffledRDD [434096] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 434097 [id="node_434097" labelType="html" label="CoalescedRDD [434097] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; 434098 [id="node_434098" labelType="html" label="MapPartitionsRDD [434098] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1089282 { id="cluster_1089282"; isCluster="true"; label="map"; 434767 [id="node_434767" labelType="html" label="MapPartitionsRDD [434767] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1089354 { id="cluster_1089354"; isCluster="true"; label="WholeStageCodegen (1)"; 434797 [id="node_434797" labelType="html" label="MapPartitionsRDD [434797] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1089352 { id="cluster_1089352"; isCluster="true"; label="Project"; 434798 [id="node_434798" labelType="html" label="MapPartitionsRDD [434798] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1089351 { id="cluster_1089351"; isCluster="true"; label="Sort"; 434799 [id="node_434799" labelType="html" label="MapPartitionsRDD [434799] [Indeterminate] start at FileStorageAdapterImpl.java:596}"]; } } 434096->434097; 434097->434098; 434098->434767; 434767->434797; 434797->434798; 434798->434799; }

434095,434096

434098

434096

434097

434098

434767

434797

434798

434799

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1036609	tenants-pool-506	stream-10000000540-2 id = 386dabc1-f677-44f7-82d8-69fe99072c2c runId = 1ebd557e-9283-4610-a07b-41d13bb785c5 batch = 31 start at FileStorageAdapterImpl.java:596 +details RDD: MapPartitionsRDD org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596) com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68) jdk.internal.reflect.GeneratedMethodAccessor615.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/09/01 14:16:48	2 s	30/30	94.9 MiB	4.9 MiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1036609

tenants-pool-506

stream-10000000540-2 id = 386dabc1-f677-44f7-82d8-69fe99072c2c runId = 1ebd557e-9283-4610-a07b-41d13bb785c5 batch = 31 start at FileStorageAdapterImpl.java:596 +details

RDD: MapPartitionsRDD

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderqtyoptservice.storageaccess.FileStorageAdapterImpl.triggerKpiCurveUpdateStream(FileStorageAdapterImpl.java:596)
com.sap.s4hana.eureka.business.crporderqtyoptservice.core.controller.OrderQuantityOptimizationStreamingActivityImpl.runStreamWithId(OrderQuantityOptimizationStreamingActivityImpl.java:68)
jdk.internal.reflect.GeneratedMethodAccessor615.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23)
io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88)
io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:109)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/09/01 14:16:48

2 s

30/30

94.9 MiB

4.9 MiB

Page:

Skipped Stages (28)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
1036608	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
1036607	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
1036606	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
1036605	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
1036604	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
1036603	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
1036602	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
1036601	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
1036600	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
1036599	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
1036598	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
1036597	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
1036596	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
1036595	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
1036594	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
1036593	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
1036592	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
1036591	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
1036590	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
1036589	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
1036588	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
1036587	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
1036586	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
1036585	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
1036584	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
1036583	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
1036582	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
1036581	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: