crp-order-quantity-kpi-service - Details for Job 52812

Status: SUCCEEDED
Submitted: 2026/08/31 14:37:20
Duration: 1 s
Associated SQL Query: 32467
Job Group: ea70e965-fb74-4f46-a423-d6f918b125d4
Completed Stages: 1
Skipped Stages: 15

Enable zooming

digraph G { id="graph_191326"; subgraph graph_stage_191326 { id="graph_stage_191326"; isCluster="true"; label="Stage 191326 (skipped)"; 426266 [id="node_426266" labelType="html" label="SQLExecutionRDD [426266] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1113856 { id="cluster_1113856"; isCluster="true"; label="Scan parquet "; 426263 [id="node_426263" labelType="html" label="FileScanRDD [426263] start at FileStorageAdapterImpl.java:179}"]; 426264 [id="node_426264" labelType="html" label="MapPartitionsRDD [426264] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113853 { id="cluster_1113853"; isCluster="true"; label="WholeStageCodegen (1)"; 426265 [id="node_426265" labelType="html" label="MapPartitionsRDD [426265] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113860 { id="cluster_1113860"; isCluster="true"; label="WholeStageCodegen (1)"; 426267 [id="node_426267" labelType="html" label="MapPartitionsRDD [426267] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113859 { id="cluster_1113859"; isCluster="true"; label="Exchange"; 426268 [id="node_426268" labelType="html" label="MapPartitionsRDD [426268] start at FileStorageAdapterImpl.java:179}"]; } } 426263->426264; 426264->426265; 426265->426266; 426266->426267; 426267->426268; }

digraph G { id="graph_191327"; subgraph graph_stage_191327 { id="graph_stage_191327"; isCluster="true"; label="Stage 191327 (skipped)"; subgraph cluster_1113859 { id="cluster_1113859"; isCluster="true"; label="Exchange"; 426269 [id="node_426269" labelType="html" label="ShuffledRowRDD [426269] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113858 { id="cluster_1113858"; isCluster="true"; label="InMemoryTableScan"; 426270 [id="node_426270" labelType="html" label="MapPartitionsRDD [426270] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426271 [id="node_426271" labelType="html" label="Exchange hashpartitioning(product#6552524, plant#6552525, 30), REPARTITION_BY_NUM, [plan_id=29069366]\n+- *(1) Scan ExistingRDD[shardId#6552521,worklistShardItemId#6552522L,version#6552523,product#6552524,plant#6552525,periodStart#6552526,periodEnd#6552527,qty#6552528]\n [426271] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114397 { id="cluster_1114397"; isCluster="true"; label="InMemoryTableScan"; 426479 [id="node_426479" labelType="html" label="MapPartitionsRDD [426479] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426480 [id="node_426480" labelType="html" label="MapPartitionsRDD [426480] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426481 [id="node_426481" labelType="html" label="MapPartitionsRDD [426481] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114393 { id="cluster_1114393"; isCluster="true"; label="WholeStageCodegen (3)"; 426482 [id="node_426482" labelType="html" label="MapPartitionsRDD [426482] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114392 { id="cluster_1114392"; isCluster="true"; label="Exchange"; 426483 [id="node_426483" labelType="html" label="MapPartitionsRDD [426483] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 426269->426270; 426270->426271; 426271->426479; 426479->426480; 426480->426481; 426481->426482; 426482->426483; }

426268,426269

426271

digraph G { id="graph_191328"; subgraph graph_stage_191328 { id="graph_stage_191328"; isCluster="true"; label="Stage 191328 (skipped)"; subgraph cluster_1114134 { id="cluster_1114134"; isCluster="true"; label="Scan parquet "; 426370 [id="node_426370" labelType="html" label="FileScanRDD [426370] start at FileStorageAdapterImpl.java:179}"]; 426371 [id="node_426371" labelType="html" label="MapPartitionsRDD [426371] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114130 { id="cluster_1114130"; isCluster="true"; label="WholeStageCodegen (10)"; 426372 [id="node_426372" labelType="html" label="MapPartitionsRDD [426372] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114129 { id="cluster_1114129"; isCluster="true"; label="Exchange"; 426373 [id="node_426373" labelType="html" label="MapPartitionsRDD [426373] start at FileStorageAdapterImpl.java:179}"]; } } 426370->426371; 426371->426372; 426372->426373; }

digraph G { id="graph_191329"; subgraph graph_stage_191329 { id="graph_stage_191329"; isCluster="true"; label="Stage 191329 (skipped)"; subgraph cluster_1114153 { id="cluster_1114153"; isCluster="true"; label="Scan parquet "; 426378 [id="node_426378" labelType="html" label="FileScanRDD [426378] start at FileStorageAdapterImpl.java:179}"]; 426379 [id="node_426379" labelType="html" label="MapPartitionsRDD [426379] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114149 { id="cluster_1114149"; isCluster="true"; label="WholeStageCodegen (12)"; 426380 [id="node_426380" labelType="html" label="MapPartitionsRDD [426380] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114148 { id="cluster_1114148"; isCluster="true"; label="Exchange"; 426381 [id="node_426381" labelType="html" label="MapPartitionsRDD [426381] start at FileStorageAdapterImpl.java:179}"]; } } 426378->426379; 426379->426380; 426380->426381; }

digraph G { id="graph_191330"; subgraph graph_stage_191330 { id="graph_stage_191330"; isCluster="true"; label="Stage 191330 (skipped)"; subgraph cluster_1114099 { id="cluster_1114099"; isCluster="true"; label="Scan parquet "; 426348 [id="node_426348" labelType="html" label="FileScanRDD [426348] start at FileStorageAdapterImpl.java:179}"]; 426349 [id="node_426349" labelType="html" label="MapPartitionsRDD [426349] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114095 { id="cluster_1114095"; isCluster="true"; label="WholeStageCodegen (3)"; 426350 [id="node_426350" labelType="html" label="MapPartitionsRDD [426350] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114094 { id="cluster_1114094"; isCluster="true"; label="Exchange"; 426351 [id="node_426351" labelType="html" label="MapPartitionsRDD [426351] start at FileStorageAdapterImpl.java:179}"]; } } 426348->426349; 426349->426350; 426350->426351; }

digraph G { id="graph_191331"; subgraph graph_stage_191331 { id="graph_stage_191331"; isCluster="true"; label="Stage 191331 (skipped)"; subgraph cluster_1114083 { id="cluster_1114083"; isCluster="true"; label="Scan parquet "; 426342 [id="node_426342" labelType="html" label="FileScanRDD [426342] start at FileStorageAdapterImpl.java:179}"]; 426343 [id="node_426343" labelType="html" label="MapPartitionsRDD [426343] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114079 { id="cluster_1114079"; isCluster="true"; label="WholeStageCodegen (1)"; 426344 [id="node_426344" labelType="html" label="MapPartitionsRDD [426344] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114078 { id="cluster_1114078"; isCluster="true"; label="Exchange"; 426345 [id="node_426345" labelType="html" label="MapPartitionsRDD [426345] start at FileStorageAdapterImpl.java:179}"]; } } 426342->426343; 426343->426344; 426344->426345; }

digraph G { id="graph_191332"; subgraph graph_stage_191332 { id="graph_stage_191332"; isCluster="true"; label="Stage 191332 (skipped)"; subgraph cluster_1113859 { id="cluster_1113859"; isCluster="true"; label="Exchange"; 426269 [id="node_426269" labelType="html" label="ShuffledRowRDD [426269] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113858 { id="cluster_1113858"; isCluster="true"; label="InMemoryTableScan"; 426270 [id="node_426270" labelType="html" label="MapPartitionsRDD [426270] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426271 [id="node_426271" labelType="html" label="Exchange hashpartitioning(product#6552524, plant#6552525, 30), REPARTITION_BY_NUM, [plan_id=29069366]\n+- *(1) Scan ExistingRDD[shardId#6552521,worklistShardItemId#6552522L,version#6552523,product#6552524,plant#6552525,periodStart#6552526,periodEnd#6552527,qty#6552528]\n [426271] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114078 { id="cluster_1114078"; isCluster="true"; label="Exchange"; 426346 [id="node_426346" labelType="html" label="ShuffledRowRDD [426346] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114074 { id="cluster_1114074"; isCluster="true"; label="WholeStageCodegen (2)"; 426347 [id="node_426347" labelType="html" label="MapPartitionsRDD [426347] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114094 { id="cluster_1114094"; isCluster="true"; label="Exchange"; 426352 [id="node_426352" labelType="html" label="ShuffledRowRDD [426352] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114090 { id="cluster_1114090"; isCluster="true"; label="WholeStageCodegen (4)"; 426353 [id="node_426353" labelType="html" label="MapPartitionsRDD [426353] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114089 { id="cluster_1114089"; isCluster="true"; label="ObjectHashAggregate"; 426354 [id="node_426354" labelType="html" label="MapPartitionsRDD [426354] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114088 { id="cluster_1114088"; isCluster="true"; label="ObjectHashAggregate"; 426355 [id="node_426355" labelType="html" label="MapPartitionsRDD [426355] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114085 { id="cluster_1114085"; isCluster="true"; label="WholeStageCodegen (5)"; 426356 [id="node_426356" labelType="html" label="MapPartitionsRDD [426356] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114070 { id="cluster_1114070"; isCluster="true"; label="WholeStageCodegen (6)"; 426357 [id="node_426357" labelType="html" label="ZippedPartitionsRDD2 [426357] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426358 [id="node_426358" labelType="html" label="MapPartitionsRDD [426358] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114106 { id="cluster_1114106"; isCluster="true"; label="InMemoryTableScan"; 426359 [id="node_426359" labelType="html" label="MapPartitionsRDD [426359] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426360 [id="node_426360" labelType="html" label="MapPartitionsRDD [426360] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426361 [id="node_426361" labelType="html" label="MapPartitionsRDD [426361] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114101 { id="cluster_1114101"; isCluster="true"; label="WholeStageCodegen (7)"; 426362 [id="node_426362" labelType="html" label="MapPartitionsRDD [426362] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114063 { id="cluster_1114063"; isCluster="true"; label="WholeStageCodegen (8)"; 426363 [id="node_426363" labelType="html" label="ZippedPartitionsRDD2 [426363] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426364 [id="node_426364" labelType="html" label="MapPartitionsRDD [426364] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114062 { id="cluster_1114062"; isCluster="true"; label="Exchange"; 426365 [id="node_426365" labelType="html" label="MapPartitionsRDD [426365] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 426269->426270; 426270->426271; 426346->426347; 426352->426353; 426353->426354; 426354->426355; 426355->426356; 426347->426357; 426356->426357; 426357->426358; 426271->426359; 426359->426360; 426360->426361; 426361->426362; 426358->426363; 426362->426363; 426363->426364; 426364->426365; }

426268,426269

426345,426346

426351,426352

426271

digraph G { id="graph_191333"; subgraph graph_stage_191333 { id="graph_stage_191333"; isCluster="true"; label="Stage 191333 (skipped)"; subgraph cluster_1113859 { id="cluster_1113859"; isCluster="true"; label="Exchange"; 426269 [id="node_426269" labelType="html" label="ShuffledRowRDD [426269] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113858 { id="cluster_1113858"; isCluster="true"; label="InMemoryTableScan"; 426270 [id="node_426270" labelType="html" label="MapPartitionsRDD [426270] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426271 [id="node_426271" labelType="html" label="Exchange hashpartitioning(product#6552524, plant#6552525, 30), REPARTITION_BY_NUM, [plan_id=29069366]\n+- *(1) Scan ExistingRDD[shardId#6552521,worklistShardItemId#6552522L,version#6552523,product#6552524,plant#6552525,periodStart#6552526,periodEnd#6552527,qty#6552528]\n [426271] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114129 { id="cluster_1114129"; isCluster="true"; label="Exchange"; 426374 [id="node_426374" labelType="html" label="ShuffledRowRDD [426374] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114126 { id="cluster_1114126"; isCluster="true"; label="WholeStageCodegen (11)"; 426375 [id="node_426375" labelType="html" label="MapPartitionsRDD [426375] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114148 { id="cluster_1114148"; isCluster="true"; label="Exchange"; 426382 [id="node_426382" labelType="html" label="ShuffledRowRDD [426382] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114143 { id="cluster_1114143"; isCluster="true"; label="WholeStageCodegen (13)"; 426383 [id="node_426383" labelType="html" label="MapPartitionsRDD [426383] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114122 { id="cluster_1114122"; isCluster="true"; label="WholeStageCodegen (14)"; 426384 [id="node_426384" labelType="html" label="ZippedPartitionsRDD2 [426384] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426385 [id="node_426385" labelType="html" label="MapPartitionsRDD [426385] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114167 { id="cluster_1114167"; isCluster="true"; label="InMemoryTableScan"; 426386 [id="node_426386" labelType="html" label="MapPartitionsRDD [426386] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426387 [id="node_426387" labelType="html" label="MapPartitionsRDD [426387] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426388 [id="node_426388" labelType="html" label="MapPartitionsRDD [426388] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114162 { id="cluster_1114162"; isCluster="true"; label="WholeStageCodegen (15)"; 426389 [id="node_426389" labelType="html" label="MapPartitionsRDD [426389] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114112 { id="cluster_1114112"; isCluster="true"; label="WholeStageCodegen (16)"; 426390 [id="node_426390" labelType="html" label="ZippedPartitionsRDD2 [426390] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426391 [id="node_426391" labelType="html" label="MapPartitionsRDD [426391] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114111 { id="cluster_1114111"; isCluster="true"; label="Exchange"; 426392 [id="node_426392" labelType="html" label="MapPartitionsRDD [426392] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 426269->426270; 426270->426271; 426374->426375; 426382->426383; 426375->426384; 426383->426384; 426384->426385; 426271->426386; 426386->426387; 426387->426388; 426388->426389; 426385->426390; 426389->426390; 426390->426391; 426391->426392; }

426268,426269

426373,426374

426381,426382

426271

digraph G { id="graph_191334"; subgraph graph_stage_191334 { id="graph_stage_191334"; isCluster="true"; label="Stage 191334 (skipped)"; subgraph cluster_1114062 { id="cluster_1114062"; isCluster="true"; label="Exchange"; 426366 [id="node_426366" labelType="html" label="ShuffledRowRDD [426366] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114059 { id="cluster_1114059"; isCluster="true"; label="WholeStageCodegen (9)"; 426367 [id="node_426367" labelType="html" label="MapPartitionsRDD [426367] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114111 { id="cluster_1114111"; isCluster="true"; label="Exchange"; 426393 [id="node_426393" labelType="html" label="ShuffledRowRDD [426393] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114108 { id="cluster_1114108"; isCluster="true"; label="WholeStageCodegen (17)"; 426394 [id="node_426394" labelType="html" label="MapPartitionsRDD [426394] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114055 { id="cluster_1114055"; isCluster="true"; label="WholeStageCodegen (18)"; 426395 [id="node_426395" labelType="html" label="ZippedPartitionsRDD2 [426395] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426396 [id="node_426396" labelType="html" label="MapPartitionsRDD [426396] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114054 { id="cluster_1114054"; isCluster="true"; label="ObjectHashAggregate"; 426397 [id="node_426397" labelType="html" label="MapPartitionsRDD [426397] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114053 { id="cluster_1114053"; isCluster="true"; label="Exchange"; 426398 [id="node_426398" labelType="html" label="MapPartitionsRDD [426398] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 426366->426367; 426393->426394; 426367->426395; 426394->426395; 426395->426396; 426396->426397; 426397->426398; }

426365,426366

426392,426393

digraph G { id="graph_191335"; subgraph graph_stage_191335 { id="graph_stage_191335"; isCluster="true"; label="Stage 191335 (skipped)"; subgraph cluster_1113859 { id="cluster_1113859"; isCluster="true"; label="Exchange"; 426269 [id="node_426269" labelType="html" label="ShuffledRowRDD [426269] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113858 { id="cluster_1113858"; isCluster="true"; label="InMemoryTableScan"; 426270 [id="node_426270" labelType="html" label="MapPartitionsRDD [426270] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426271 [id="node_426271" labelType="html" label="Exchange hashpartitioning(product#6552524, plant#6552525, 30), REPARTITION_BY_NUM, [plan_id=29069366]\n+- *(1) Scan ExistingRDD[shardId#6552521,worklistShardItemId#6552522L,version#6552523,product#6552524,plant#6552525,periodStart#6552526,periodEnd#6552527,qty#6552528]\n [426271] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114179 { id="cluster_1114179"; isCluster="true"; label="InMemoryTableScan"; 426405 [id="node_426405" labelType="html" label="MapPartitionsRDD [426405] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426406 [id="node_426406" labelType="html" label="MapPartitionsRDD [426406] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426407 [id="node_426407" labelType="html" label="MapPartitionsRDD [426407] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114176 { id="cluster_1114176"; isCluster="true"; label="WholeStageCodegen (20)"; 426408 [id="node_426408" labelType="html" label="MapPartitionsRDD [426408] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114175 { id="cluster_1114175"; isCluster="true"; label="ObjectHashAggregate"; 426409 [id="node_426409" labelType="html" label="MapPartitionsRDD [426409] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114174 { id="cluster_1114174"; isCluster="true"; label="ObjectHashAggregate"; 426410 [id="node_426410" labelType="html" label="MapPartitionsRDD [426410] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114184 { id="cluster_1114184"; isCluster="true"; label="InMemoryTableScan"; 426411 [id="node_426411" labelType="html" label="MapPartitionsRDD [426411] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426412 [id="node_426412" labelType="html" label="MapPartitionsRDD [426412] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426413 [id="node_426413" labelType="html" label="MapPartitionsRDD [426413] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114180 { id="cluster_1114180"; isCluster="true"; label="WholeStageCodegen (21)"; 426414 [id="node_426414" labelType="html" label="MapPartitionsRDD [426414] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114173 { id="cluster_1114173"; isCluster="true"; label="Union"; 426415 [id="node_426415" labelType="html" label="UnionRDD [426415] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114172 { id="cluster_1114172"; isCluster="true"; label="Exchange"; 426416 [id="node_426416" labelType="html" label="MapPartitionsRDD [426416] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 426269->426270; 426270->426271; 426271->426405; 426405->426406; 426406->426407; 426407->426408; 426408->426409; 426409->426410; 426271->426411; 426411->426412; 426412->426413; 426413->426414; 426410->426415; 426414->426415; 426415->426416; }

426268,426269

426271

digraph G { id="graph_191336"; subgraph graph_stage_191336 { id="graph_stage_191336"; isCluster="true"; label="Stage 191336 (skipped)"; subgraph cluster_1114053 { id="cluster_1114053"; isCluster="true"; label="Exchange"; 426399 [id="node_426399" labelType="html" label="ShuffledRowRDD [426399] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114052 { id="cluster_1114052"; isCluster="true"; label="ObjectHashAggregate"; 426400 [id="node_426400" labelType="html" label="MapPartitionsRDD [426400] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114051 { id="cluster_1114051"; isCluster="true"; label="Project"; 426401 [id="node_426401" labelType="html" label="MapPartitionsRDD [426401] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114050 { id="cluster_1114050"; isCluster="true"; label="Exchange"; 426402 [id="node_426402" labelType="html" label="MapPartitionsRDD [426402] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 426399->426400; 426400->426401; 426401->426402; }

426398,426399

digraph G { id="graph_191337"; subgraph graph_stage_191337 { id="graph_stage_191337"; isCluster="true"; label="Stage 191337 (skipped)"; 426425 [id="node_426425" labelType="html" label="SQLExecutionRDD [426425] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1114050 { id="cluster_1114050"; isCluster="true"; label="Exchange"; 426403 [id="node_426403" labelType="html" label="ShuffledRowRDD [426403] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114047 { id="cluster_1114047"; isCluster="true"; label="WholeStageCodegen (19)"; 426404 [id="node_426404" labelType="html" label="MapPartitionsRDD [426404] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114172 { id="cluster_1114172"; isCluster="true"; label="Exchange"; 426417 [id="node_426417" labelType="html" label="ShuffledRowRDD [426417] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114169 { id="cluster_1114169"; isCluster="true"; label="WholeStageCodegen (22)"; 426418 [id="node_426418" labelType="html" label="MapPartitionsRDD [426418] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114042 { id="cluster_1114042"; isCluster="true"; label="WholeStageCodegen (23)"; 426419 [id="node_426419" labelType="html" label="ZippedPartitionsRDD2 [426419] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426420 [id="node_426420" labelType="html" label="MapPartitionsRDD [426420] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114041 { id="cluster_1114041"; isCluster="true"; label="DeserializeToObject"; 426421 [id="node_426421" labelType="html" label="MapPartitionsRDD [426421] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114040 { id="cluster_1114040"; isCluster="true"; label="MapPartitions"; 426422 [id="node_426422" labelType="html" label="MapPartitionsRDD [426422] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114018 { id="cluster_1114018"; isCluster="true"; label="WholeStageCodegen (26)"; 426423 [id="node_426423" labelType="html" label="MapPartitionsRDD [426423] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114017 { id="cluster_1114017"; isCluster="true"; label="DeserializeToObject"; 426424 [id="node_426424" labelType="html" label="MapPartitionsRDD [426424] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114185 { id="cluster_1114185"; isCluster="true"; label="mapPartitions"; 426426 [id="node_426426" labelType="html" label="MapPartitionsRDD [426426] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114186 { id="cluster_1114186"; isCluster="true"; label="mapPartitions"; 426427 [id="node_426427" labelType="html" label="MapPartitionsRDD [426427] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114299 { id="cluster_1114299"; isCluster="true"; label="Scan"; 426428 [id="node_426428" labelType="html" label="MapPartitionsRDD [426428] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114293 { id="cluster_1114293"; isCluster="true"; label="WholeStageCodegen (1)"; 426429 [id="node_426429" labelType="html" label="MapPartitionsRDD [426429] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114292 { id="cluster_1114292"; isCluster="true"; label="InMemoryTableScan"; 426430 [id="node_426430" labelType="html" label="MapPartitionsRDD [426430] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426431 [id="node_426431" labelType="html" label="*(1) Generate explode(prodPlantResults#6877322), false, [prodPlantResults#6877329]\n+- *(1) Project [prodPlantResults#6877322]\n +- *(1) Filter ((size(prodPlantResults#6877322, true) > 0) AND isnotnull(prodPlantResults#6877322))\n +- *(1) SerializeFromObject [mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement)))) null else named_struct(measuredUnit, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,String... [426431] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426432 [id="node_426432" labelType="html" label="MapPartitionsRDD [426432] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426433 [id="node_426433" labelType="html" label="MapPartitionsRDD [426433] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426434 [id="node_426434" labelType="html" label="MapPartitionsRDD [426434] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114291 { id="cluster_1114291"; isCluster="true"; label="Project"; 426435 [id="node_426435" labelType="html" label="MapPartitionsRDD [426435] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114306 { id="cluster_1114306"; isCluster="true"; label="InMemoryTableScan"; 426436 [id="node_426436" labelType="html" label="MapPartitionsRDD [426436] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426437 [id="node_426437" labelType="html" label="MapPartitionsRDD [426437] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426438 [id="node_426438" labelType="html" label="MapPartitionsRDD [426438] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114301 { id="cluster_1114301"; isCluster="true"; label="WholeStageCodegen (1)"; 426439 [id="node_426439" labelType="html" label="MapPartitionsRDD [426439] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114300 { id="cluster_1114300"; isCluster="true"; label="Project"; 426440 [id="node_426440" labelType="html" label="MapPartitionsRDD [426440] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114313 { id="cluster_1114313"; isCluster="true"; label="InMemoryTableScan"; 426441 [id="node_426441" labelType="html" label="MapPartitionsRDD [426441] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426442 [id="node_426442" labelType="html" label="MapPartitionsRDD [426442] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426443 [id="node_426443" labelType="html" label="MapPartitionsRDD [426443] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114308 { id="cluster_1114308"; isCluster="true"; label="WholeStageCodegen (2)"; 426444 [id="node_426444" labelType="html" label="MapPartitionsRDD [426444] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114307 { id="cluster_1114307"; isCluster="true"; label="Project"; 426445 [id="node_426445" labelType="html" label="MapPartitionsRDD [426445] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114290 { id="cluster_1114290"; isCluster="true"; label="Union"; 426446 [id="node_426446" labelType="html" label="UnionRDD [426446] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114289 { id="cluster_1114289"; isCluster="true"; label="Exchange"; 426447 [id="node_426447" labelType="html" label="MapPartitionsRDD [426447] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 426403->426404; 426417->426418; 426404->426419; 426418->426419; 426419->426420; 426420->426421; 426421->426422; 426422->426423; 426423->426424; 426424->426425; 426425->426426; 426426->426427; 426427->426428; 426428->426429; 426429->426430; 426430->426431; 426431->426432; 426432->426433; 426433->426434; 426434->426435; 426431->426436; 426436->426437; 426437->426438; 426438->426439; 426439->426440; 426431->426441; 426441->426442; 426442->426443; 426443->426444; 426444->426445; 426435->426446; 426440->426446; 426445->426446; 426446->426447; }

426402,426403

426416,426417

426427

426431

digraph G { id="graph_191338"; subgraph graph_stage_191338 { id="graph_stage_191338"; isCluster="true"; label="Stage 191338 (skipped)"; subgraph cluster_1113859 { id="cluster_1113859"; isCluster="true"; label="Exchange"; 426269 [id="node_426269" labelType="html" label="ShuffledRowRDD [426269] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113858 { id="cluster_1113858"; isCluster="true"; label="InMemoryTableScan"; 426270 [id="node_426270" labelType="html" label="MapPartitionsRDD [426270] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426271 [id="node_426271" labelType="html" label="Exchange hashpartitioning(product#6552524, plant#6552525, 30), REPARTITION_BY_NUM, [plan_id=29069366]\n+- *(1) Scan ExistingRDD[shardId#6552521,worklistShardItemId#6552522L,version#6552523,product#6552524,plant#6552525,periodStart#6552526,periodEnd#6552527,qty#6552528]\n [426271] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114323 { id="cluster_1114323"; isCluster="true"; label="InMemoryTableScan"; 426450 [id="node_426450" labelType="html" label="MapPartitionsRDD [426450] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426451 [id="node_426451" labelType="html" label="MapPartitionsRDD [426451] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426452 [id="node_426452" labelType="html" label="MapPartitionsRDD [426452] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114319 { id="cluster_1114319"; isCluster="true"; label="WholeStageCodegen (4)"; 426453 [id="node_426453" labelType="html" label="MapPartitionsRDD [426453] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114318 { id="cluster_1114318"; isCluster="true"; label="Exchange"; 426454 [id="node_426454" labelType="html" label="MapPartitionsRDD [426454] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 426269->426270; 426270->426271; 426271->426450; 426450->426451; 426451->426452; 426452->426453; 426453->426454; }

426268,426269

426271

digraph G { id="graph_191339"; subgraph graph_stage_191339 { id="graph_stage_191339"; isCluster="true"; label="Stage 191339 (skipped)"; subgraph cluster_1114289 { id="cluster_1114289"; isCluster="true"; label="Exchange"; 426448 [id="node_426448" labelType="html" label="ShuffledRowRDD [426448] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114286 { id="cluster_1114286"; isCluster="true"; label="WholeStageCodegen (3)"; 426449 [id="node_426449" labelType="html" label="MapPartitionsRDD [426449] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114318 { id="cluster_1114318"; isCluster="true"; label="Exchange"; 426455 [id="node_426455" labelType="html" label="ShuffledRowRDD [426455] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114315 { id="cluster_1114315"; isCluster="true"; label="WholeStageCodegen (5)"; 426456 [id="node_426456" labelType="html" label="MapPartitionsRDD [426456] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114281 { id="cluster_1114281"; isCluster="true"; label="WholeStageCodegen (6)"; 426457 [id="node_426457" labelType="html" label="ZippedPartitionsRDD2 [426457] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426458 [id="node_426458" labelType="html" label="MapPartitionsRDD [426458] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114280 { id="cluster_1114280"; isCluster="true"; label="SortAggregate"; 426459 [id="node_426459" labelType="html" label="MapPartitionsRDD [426459] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114279 { id="cluster_1114279"; isCluster="true"; label="Exchange"; 426460 [id="node_426460" labelType="html" label="MapPartitionsRDD [426460] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 426448->426449; 426455->426456; 426449->426457; 426456->426457; 426457->426458; 426458->426459; 426459->426460; }

426447,426448

426454,426455

digraph G { id="graph_191340"; subgraph graph_stage_191340 { id="graph_stage_191340"; isCluster="true"; label="Stage 191340 (skipped)"; subgraph cluster_1114279 { id="cluster_1114279"; isCluster="true"; label="Exchange"; 426461 [id="node_426461" labelType="html" label="ShuffledRowRDD [426461] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114276 { id="cluster_1114276"; isCluster="true"; label="WholeStageCodegen (7)"; 426462 [id="node_426462" labelType="html" label="MapPartitionsRDD [426462] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114275 { id="cluster_1114275"; isCluster="true"; label="SortAggregate"; 426463 [id="node_426463" labelType="html" label="MapPartitionsRDD [426463] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114274 { id="cluster_1114274"; isCluster="true"; label="InMemoryTableScan"; 426464 [id="node_426464" labelType="html" label="MapPartitionsRDD [426464] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426465 [id="node_426465" labelType="html" label="SortAggregate(key=[demandChannel#6877355, shardId#6552521, qty#6877375, worklistShardItemId#6552522L, demandStream#6877356], functions=[first(kpis#6877384, false)], output=[shardId#6552521, worklistShardItemId#6552522L, qty#6877375, demandChannel#6877355, demandStream#6877356, kpis#6877497])\n+- *(7) Sort [demandChannel#6877355 ASC NULLS FIRST, shardId#6552521 ASC NULLS FIRST, qty#6877375 ASC NULLS FIRST, worklistShardItemId#6552522L ASC NULLS FIRST, demandStream#6877356 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6877355, shardId#6552521, qty#6877375, worklistShardItemId#6552522L, demandStream#6877356, 30), ENSURE_REQUIREMENTS, [plan_id=29070493]\n +- SortAggregate(key=[demandChannel#6877355, shardId#6552521, knownfloatingpointnormalized(normalizenanandzero(qty#6877375)) AS qty#6877375, worklistShardItemId#6552522L, demandStream#6877356], functions=[partial_first(kpis#6877384, false)], output=[demandChannel#6877355, shardId#6552521, qty#6877375, worklistShardItemId#6552522L... [426465] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114386 { id="cluster_1114386"; isCluster="true"; label="InMemoryTableScan"; 426472 [id="node_426472" labelType="html" label="MapPartitionsRDD [426472] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426473 [id="node_426473" labelType="html" label="MapPartitionsRDD [426473] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426474 [id="node_426474" labelType="html" label="MapPartitionsRDD [426474] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114383 { id="cluster_1114383"; isCluster="true"; label="WholeStageCodegen (1)"; 426475 [id="node_426475" labelType="html" label="MapPartitionsRDD [426475] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114382 { id="cluster_1114382"; isCluster="true"; label="Exchange"; 426476 [id="node_426476" labelType="html" label="MapPartitionsRDD [426476] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 426461->426462; 426462->426463; 426463->426464; 426464->426465; 426465->426472; 426472->426473; 426473->426474; 426474->426475; 426475->426476; }

426460,426461

426465

digraph G { id="graph_191341"; subgraph graph_stage_191341 { id="graph_stage_191341"; isCluster="true"; label="Stage 191341"; subgraph cluster_1114382 { id="cluster_1114382"; isCluster="true"; label="Exchange"; 426477 [id="node_426477" labelType="html" label="ShuffledRowRDD [426477] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114379 { id="cluster_1114379"; isCluster="true"; label="WholeStageCodegen (2)"; 426478 [id="node_426478" labelType="html" label="MapPartitionsRDD [426478] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114392 { id="cluster_1114392"; isCluster="true"; label="Exchange"; 426484 [id="node_426484" labelType="html" label="ShuffledRowRDD [426484] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114388 { id="cluster_1114388"; isCluster="true"; label="WholeStageCodegen (4)"; 426485 [id="node_426485" labelType="html" label="MapPartitionsRDD [426485] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114375 { id="cluster_1114375"; isCluster="true"; label="WholeStageCodegen (5)"; 426486 [id="node_426486" labelType="html" label="ZippedPartitionsRDD2 [426486] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426487 [id="node_426487" labelType="html" label="MapPartitionsRDD [426487] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114374 { id="cluster_1114374"; isCluster="true"; label="InMemoryTableScan"; 426488 [id="node_426488" labelType="html" label="MapPartitionsRDD [426488] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426489 [id="node_426489" labelType="html" label="*(5) Project [shardId#6552521, worklistShardItemId#6552522L, version#6877846, qty#6877375, demandChannel#6877355, demandStream#6877356, kpis#6877384]\n+- *(5) SortMergeJoin [shardId#6552521, worklistShardItemId#6552522L], [shardId#6877851, worklistShardItemId#6877852L], Inner\n :- *(2) Sort [shardId#6552521 ASC NULLS FIRST, worklistShardItemId#6552522L ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(shardId#6552521, worklistShardItemId#6552522L, 30), ENSURE_REQUIREMENTS, [plan_id=29070601]\n : +- *(1) Filter (isnotnull(shardId#6552521) AND isnotnull(worklistShardItemId#6552522L))\n : +- InMemoryTableScan [shardId#6552521, worklistShardItemId#6552522L, qty#6877375, demandChannel#6877355, demandStream#6877356, kpis#6877384], [isnotnull(shardId#6552521), isnotnull(worklistShardItemId#6552522L)]\n : +- InMemoryRelation [shardId#6552521, worklistShardItemId#6552522L, qty#6877375, demandChannel#6877355, demandStream#6877356, kpis#6877384], StorageLevel(disk, memory, 2 rep... [426489] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114428 { id="cluster_1114428"; isCluster="true"; label="InMemoryTableScan"; 426498 [id="node_426498" labelType="html" label="MapPartitionsRDD [426498] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426499 [id="node_426499" labelType="html" label="MapPartitionsRDD [426499] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426500 [id="node_426500" labelType="html" label="MapPartitionsRDD [426500] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 426477->426478; 426484->426485; 426478->426486; 426485->426486; 426486->426487; 426487->426488; 426488->426489; 426489->426498; 426498->426499; 426499->426500; }

426476,426477

426483,426484

426489

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
191341	tenants-pool-506	stream-10000000532-2 id = 9167552c-3a3b-4751-bcdc-2f80fd16759c runId = ea70e965-fb74-4f46-a423-d6f918b125d4 batch = 18 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:109) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:341) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:293) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:255) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:80) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/08/31 14:37:20	1 s	30/30	12.5 MiB	3.0 MiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

191341

tenants-pool-506

stream-10000000532-2 id = 9167552c-3a3b-4751-bcdc-2f80fd16759c runId = ea70e965-fb74-4f46-a423-d6f918b125d4 batch = 18 start at FileStorageAdapterImpl.java:179 +details

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

2026/08/31 14:37:20

1 s

30/30

12.5 MiB

3.0 MiB

Page:

Skipped Stages (15)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
191340	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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
191339	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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
191338	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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
191337	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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/90
191336	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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
191335	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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
191334	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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
191333	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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
191332	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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
191331	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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
191330	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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/34
191329	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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/34
191328	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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
191327	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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
191326	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor984.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

Page: