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

Status: SUCCEEDED
Submitted: 2026/09/01 14:16:19
Duration: 0.9 s
Associated SQL Query: 41136
Job Group: e97f90ad-57e2-4862-afd3-46c7c1a84cab
Completed Stages: 1
Skipped Stages: 15

Enable zooming

digraph G { id="graph_241614"; subgraph graph_stage_241614 { id="graph_stage_241614"; isCluster="true"; label="Stage 241614 (skipped)"; 540583 [id="node_540583" labelType="html" label="SQLExecutionRDD [540583] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1411764 { id="cluster_1411764"; isCluster="true"; label="Scan parquet "; 540580 [id="node_540580" labelType="html" label="FileScanRDD [540580] start at FileStorageAdapterImpl.java:179}"]; 540581 [id="node_540581" labelType="html" label="MapPartitionsRDD [540581] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411761 { id="cluster_1411761"; isCluster="true"; label="WholeStageCodegen (1)"; 540582 [id="node_540582" labelType="html" label="MapPartitionsRDD [540582] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411768 { id="cluster_1411768"; isCluster="true"; label="WholeStageCodegen (1)"; 540584 [id="node_540584" labelType="html" label="MapPartitionsRDD [540584] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411767 { id="cluster_1411767"; isCluster="true"; label="Exchange"; 540585 [id="node_540585" labelType="html" label="MapPartitionsRDD [540585] start at FileStorageAdapterImpl.java:179}"]; } } 540580->540581; 540581->540582; 540582->540583; 540583->540584; 540584->540585; }

digraph G { id="graph_241615"; subgraph graph_stage_241615 { id="graph_stage_241615"; isCluster="true"; label="Stage 241615 (skipped)"; subgraph cluster_1412000 { id="cluster_1412000"; isCluster="true"; label="Scan parquet "; 540663 [id="node_540663" labelType="html" label="FileScanRDD [540663] start at FileStorageAdapterImpl.java:179}"]; 540664 [id="node_540664" labelType="html" label="MapPartitionsRDD [540664] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411996 { id="cluster_1411996"; isCluster="true"; label="WholeStageCodegen (1)"; 540665 [id="node_540665" labelType="html" label="MapPartitionsRDD [540665] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411995 { id="cluster_1411995"; isCluster="true"; label="Exchange"; 540666 [id="node_540666" labelType="html" label="MapPartitionsRDD [540666] start at FileStorageAdapterImpl.java:179}"]; } } 540663->540664; 540664->540665; 540665->540666; }

digraph G { id="graph_241616"; subgraph graph_stage_241616 { id="graph_stage_241616"; isCluster="true"; label="Stage 241616 (skipped)"; subgraph cluster_1412016 { id="cluster_1412016"; isCluster="true"; label="Scan parquet "; 540669 [id="node_540669" labelType="html" label="FileScanRDD [540669] start at FileStorageAdapterImpl.java:179}"]; 540670 [id="node_540670" labelType="html" label="MapPartitionsRDD [540670] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412012 { id="cluster_1412012"; isCluster="true"; label="WholeStageCodegen (3)"; 540671 [id="node_540671" labelType="html" label="MapPartitionsRDD [540671] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412011 { id="cluster_1412011"; isCluster="true"; label="Exchange"; 540672 [id="node_540672" labelType="html" label="MapPartitionsRDD [540672] start at FileStorageAdapterImpl.java:179}"]; } } 540669->540670; 540670->540671; 540671->540672; }

digraph G { id="graph_241617"; subgraph graph_stage_241617 { id="graph_stage_241617"; isCluster="true"; label="Stage 241617 (skipped)"; subgraph cluster_1412070 { id="cluster_1412070"; isCluster="true"; label="Scan parquet "; 540699 [id="node_540699" labelType="html" label="FileScanRDD [540699] start at FileStorageAdapterImpl.java:179}"]; 540700 [id="node_540700" labelType="html" label="MapPartitionsRDD [540700] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412066 { id="cluster_1412066"; isCluster="true"; label="WholeStageCodegen (12)"; 540701 [id="node_540701" labelType="html" label="MapPartitionsRDD [540701] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412065 { id="cluster_1412065"; isCluster="true"; label="Exchange"; 540702 [id="node_540702" labelType="html" label="MapPartitionsRDD [540702] start at FileStorageAdapterImpl.java:179}"]; } } 540699->540700; 540700->540701; 540701->540702; }

digraph G { id="graph_241618"; subgraph graph_stage_241618 { id="graph_stage_241618"; isCluster="true"; label="Stage 241618 (skipped)"; subgraph cluster_1412051 { id="cluster_1412051"; isCluster="true"; label="Scan parquet "; 540691 [id="node_540691" labelType="html" label="FileScanRDD [540691] start at FileStorageAdapterImpl.java:179}"]; 540692 [id="node_540692" labelType="html" label="MapPartitionsRDD [540692] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412047 { id="cluster_1412047"; isCluster="true"; label="WholeStageCodegen (10)"; 540693 [id="node_540693" labelType="html" label="MapPartitionsRDD [540693] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412046 { id="cluster_1412046"; isCluster="true"; label="Exchange"; 540694 [id="node_540694" labelType="html" label="MapPartitionsRDD [540694] start at FileStorageAdapterImpl.java:179}"]; } } 540691->540692; 540692->540693; 540693->540694; }

digraph G { id="graph_241619"; subgraph graph_stage_241619 { id="graph_stage_241619"; isCluster="true"; label="Stage 241619 (skipped)"; subgraph cluster_1411767 { id="cluster_1411767"; isCluster="true"; label="Exchange"; 540586 [id="node_540586" labelType="html" label="ShuffledRowRDD [540586] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411766 { id="cluster_1411766"; isCluster="true"; label="InMemoryTableScan"; 540587 [id="node_540587" labelType="html" label="MapPartitionsRDD [540587] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540588 [id="node_540588" labelType="html" label="Exchange hashpartitioning(product#8398783, plant#8398784, 30), REPARTITION_BY_NUM, [plan_id=36546947]\n+- *(1) Scan ExistingRDD[shardId#8398780,worklistShardItemId#8398781L,version#8398782,product#8398783,plant#8398784,periodStart#8398785,periodEnd#8398786,qty#8398787]\n [540588] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412046 { id="cluster_1412046"; isCluster="true"; label="Exchange"; 540695 [id="node_540695" labelType="html" label="ShuffledRowRDD [540695] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412043 { id="cluster_1412043"; isCluster="true"; label="WholeStageCodegen (11)"; 540696 [id="node_540696" labelType="html" label="MapPartitionsRDD [540696] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412065 { id="cluster_1412065"; isCluster="true"; label="Exchange"; 540703 [id="node_540703" labelType="html" label="ShuffledRowRDD [540703] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412060 { id="cluster_1412060"; isCluster="true"; label="WholeStageCodegen (13)"; 540704 [id="node_540704" labelType="html" label="MapPartitionsRDD [540704] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412039 { id="cluster_1412039"; isCluster="true"; label="WholeStageCodegen (14)"; 540705 [id="node_540705" labelType="html" label="ZippedPartitionsRDD2 [540705] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540706 [id="node_540706" labelType="html" label="MapPartitionsRDD [540706] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412084 { id="cluster_1412084"; isCluster="true"; label="InMemoryTableScan"; 540707 [id="node_540707" labelType="html" label="MapPartitionsRDD [540707] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540708 [id="node_540708" labelType="html" label="MapPartitionsRDD [540708] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540709 [id="node_540709" labelType="html" label="MapPartitionsRDD [540709] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412079 { id="cluster_1412079"; isCluster="true"; label="WholeStageCodegen (15)"; 540710 [id="node_540710" labelType="html" label="MapPartitionsRDD [540710] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412029 { id="cluster_1412029"; isCluster="true"; label="WholeStageCodegen (16)"; 540711 [id="node_540711" labelType="html" label="ZippedPartitionsRDD2 [540711] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540712 [id="node_540712" labelType="html" label="MapPartitionsRDD [540712] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412028 { id="cluster_1412028"; isCluster="true"; label="Exchange"; 540713 [id="node_540713" labelType="html" label="MapPartitionsRDD [540713] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540586->540587; 540587->540588; 540695->540696; 540703->540704; 540696->540705; 540704->540705; 540705->540706; 540588->540707; 540707->540708; 540708->540709; 540709->540710; 540706->540711; 540710->540711; 540711->540712; 540712->540713; }

540585,540586

540694,540695

540702,540703

540588

digraph G { id="graph_241620"; subgraph graph_stage_241620 { id="graph_stage_241620"; isCluster="true"; label="Stage 241620 (skipped)"; subgraph cluster_1411767 { id="cluster_1411767"; isCluster="true"; label="Exchange"; 540586 [id="node_540586" labelType="html" label="ShuffledRowRDD [540586] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411766 { id="cluster_1411766"; isCluster="true"; label="InMemoryTableScan"; 540587 [id="node_540587" labelType="html" label="MapPartitionsRDD [540587] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540588 [id="node_540588" labelType="html" label="Exchange hashpartitioning(product#8398783, plant#8398784, 30), REPARTITION_BY_NUM, [plan_id=36546947]\n+- *(1) Scan ExistingRDD[shardId#8398780,worklistShardItemId#8398781L,version#8398782,product#8398783,plant#8398784,periodStart#8398785,periodEnd#8398786,qty#8398787]\n [540588] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411995 { id="cluster_1411995"; isCluster="true"; label="Exchange"; 540667 [id="node_540667" labelType="html" label="ShuffledRowRDD [540667] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411991 { id="cluster_1411991"; isCluster="true"; label="WholeStageCodegen (2)"; 540668 [id="node_540668" labelType="html" label="MapPartitionsRDD [540668] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412011 { id="cluster_1412011"; isCluster="true"; label="Exchange"; 540673 [id="node_540673" labelType="html" label="ShuffledRowRDD [540673] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412007 { id="cluster_1412007"; isCluster="true"; label="WholeStageCodegen (4)"; 540674 [id="node_540674" labelType="html" label="MapPartitionsRDD [540674] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412006 { id="cluster_1412006"; isCluster="true"; label="ObjectHashAggregate"; 540675 [id="node_540675" labelType="html" label="MapPartitionsRDD [540675] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412005 { id="cluster_1412005"; isCluster="true"; label="ObjectHashAggregate"; 540676 [id="node_540676" labelType="html" label="MapPartitionsRDD [540676] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412002 { id="cluster_1412002"; isCluster="true"; label="WholeStageCodegen (5)"; 540677 [id="node_540677" labelType="html" label="MapPartitionsRDD [540677] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411987 { id="cluster_1411987"; isCluster="true"; label="WholeStageCodegen (6)"; 540678 [id="node_540678" labelType="html" label="ZippedPartitionsRDD2 [540678] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540679 [id="node_540679" labelType="html" label="MapPartitionsRDD [540679] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412023 { id="cluster_1412023"; isCluster="true"; label="InMemoryTableScan"; 540680 [id="node_540680" labelType="html" label="MapPartitionsRDD [540680] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540681 [id="node_540681" labelType="html" label="MapPartitionsRDD [540681] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540682 [id="node_540682" labelType="html" label="MapPartitionsRDD [540682] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412018 { id="cluster_1412018"; isCluster="true"; label="WholeStageCodegen (7)"; 540683 [id="node_540683" labelType="html" label="MapPartitionsRDD [540683] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411980 { id="cluster_1411980"; isCluster="true"; label="WholeStageCodegen (8)"; 540684 [id="node_540684" labelType="html" label="ZippedPartitionsRDD2 [540684] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540685 [id="node_540685" labelType="html" label="MapPartitionsRDD [540685] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411979 { id="cluster_1411979"; isCluster="true"; label="Exchange"; 540686 [id="node_540686" labelType="html" label="MapPartitionsRDD [540686] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540586->540587; 540587->540588; 540667->540668; 540673->540674; 540674->540675; 540675->540676; 540676->540677; 540668->540678; 540677->540678; 540678->540679; 540588->540680; 540680->540681; 540681->540682; 540682->540683; 540679->540684; 540683->540684; 540684->540685; 540685->540686; }

540585,540586

540666,540667

540672,540673

540588

digraph G { id="graph_241621"; subgraph graph_stage_241621 { id="graph_stage_241621"; isCluster="true"; label="Stage 241621 (skipped)"; subgraph cluster_1411979 { id="cluster_1411979"; isCluster="true"; label="Exchange"; 540687 [id="node_540687" labelType="html" label="ShuffledRowRDD [540687] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411976 { id="cluster_1411976"; isCluster="true"; label="WholeStageCodegen (9)"; 540688 [id="node_540688" labelType="html" label="MapPartitionsRDD [540688] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412028 { id="cluster_1412028"; isCluster="true"; label="Exchange"; 540714 [id="node_540714" labelType="html" label="ShuffledRowRDD [540714] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412025 { id="cluster_1412025"; isCluster="true"; label="WholeStageCodegen (17)"; 540715 [id="node_540715" labelType="html" label="MapPartitionsRDD [540715] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411972 { id="cluster_1411972"; isCluster="true"; label="WholeStageCodegen (18)"; 540716 [id="node_540716" labelType="html" label="ZippedPartitionsRDD2 [540716] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540717 [id="node_540717" labelType="html" label="MapPartitionsRDD [540717] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411971 { id="cluster_1411971"; isCluster="true"; label="ObjectHashAggregate"; 540718 [id="node_540718" labelType="html" label="MapPartitionsRDD [540718] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411970 { id="cluster_1411970"; isCluster="true"; label="Exchange"; 540719 [id="node_540719" labelType="html" label="MapPartitionsRDD [540719] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540687->540688; 540714->540715; 540688->540716; 540715->540716; 540716->540717; 540717->540718; 540718->540719; }

540686,540687

540713,540714

digraph G { id="graph_241622"; subgraph graph_stage_241622 { id="graph_stage_241622"; isCluster="true"; label="Stage 241622 (skipped)"; subgraph cluster_1411767 { id="cluster_1411767"; isCluster="true"; label="Exchange"; 540586 [id="node_540586" labelType="html" label="ShuffledRowRDD [540586] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411766 { id="cluster_1411766"; isCluster="true"; label="InMemoryTableScan"; 540587 [id="node_540587" labelType="html" label="MapPartitionsRDD [540587] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540588 [id="node_540588" labelType="html" label="Exchange hashpartitioning(product#8398783, plant#8398784, 30), REPARTITION_BY_NUM, [plan_id=36546947]\n+- *(1) Scan ExistingRDD[shardId#8398780,worklistShardItemId#8398781L,version#8398782,product#8398783,plant#8398784,periodStart#8398785,periodEnd#8398786,qty#8398787]\n [540588] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412096 { id="cluster_1412096"; isCluster="true"; label="InMemoryTableScan"; 540726 [id="node_540726" labelType="html" label="MapPartitionsRDD [540726] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540727 [id="node_540727" labelType="html" label="MapPartitionsRDD [540727] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540728 [id="node_540728" labelType="html" label="MapPartitionsRDD [540728] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412093 { id="cluster_1412093"; isCluster="true"; label="WholeStageCodegen (20)"; 540729 [id="node_540729" labelType="html" label="MapPartitionsRDD [540729] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412092 { id="cluster_1412092"; isCluster="true"; label="ObjectHashAggregate"; 540730 [id="node_540730" labelType="html" label="MapPartitionsRDD [540730] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412091 { id="cluster_1412091"; isCluster="true"; label="ObjectHashAggregate"; 540731 [id="node_540731" labelType="html" label="MapPartitionsRDD [540731] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412101 { id="cluster_1412101"; isCluster="true"; label="InMemoryTableScan"; 540732 [id="node_540732" labelType="html" label="MapPartitionsRDD [540732] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540733 [id="node_540733" labelType="html" label="MapPartitionsRDD [540733] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540734 [id="node_540734" labelType="html" label="MapPartitionsRDD [540734] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412097 { id="cluster_1412097"; isCluster="true"; label="WholeStageCodegen (21)"; 540735 [id="node_540735" labelType="html" label="MapPartitionsRDD [540735] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412090 { id="cluster_1412090"; isCluster="true"; label="Union"; 540736 [id="node_540736" labelType="html" label="UnionRDD [540736] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412089 { id="cluster_1412089"; isCluster="true"; label="Exchange"; 540737 [id="node_540737" labelType="html" label="MapPartitionsRDD [540737] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540586->540587; 540587->540588; 540588->540726; 540726->540727; 540727->540728; 540728->540729; 540729->540730; 540730->540731; 540588->540732; 540732->540733; 540733->540734; 540734->540735; 540731->540736; 540735->540736; 540736->540737; }

540585,540586

540588

digraph G { id="graph_241623"; subgraph graph_stage_241623 { id="graph_stage_241623"; isCluster="true"; label="Stage 241623 (skipped)"; subgraph cluster_1411970 { id="cluster_1411970"; isCluster="true"; label="Exchange"; 540720 [id="node_540720" labelType="html" label="ShuffledRowRDD [540720] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411969 { id="cluster_1411969"; isCluster="true"; label="ObjectHashAggregate"; 540721 [id="node_540721" labelType="html" label="MapPartitionsRDD [540721] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411968 { id="cluster_1411968"; isCluster="true"; label="Project"; 540722 [id="node_540722" labelType="html" label="MapPartitionsRDD [540722] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411967 { id="cluster_1411967"; isCluster="true"; label="Exchange"; 540723 [id="node_540723" labelType="html" label="MapPartitionsRDD [540723] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540720->540721; 540721->540722; 540722->540723; }

540719,540720

digraph G { id="graph_241624"; subgraph graph_stage_241624 { id="graph_stage_241624"; isCluster="true"; label="Stage 241624 (skipped)"; 540746 [id="node_540746" labelType="html" label="SQLExecutionRDD [540746] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1411967 { id="cluster_1411967"; isCluster="true"; label="Exchange"; 540724 [id="node_540724" labelType="html" label="ShuffledRowRDD [540724] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411964 { id="cluster_1411964"; isCluster="true"; label="WholeStageCodegen (19)"; 540725 [id="node_540725" labelType="html" label="MapPartitionsRDD [540725] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412089 { id="cluster_1412089"; isCluster="true"; label="Exchange"; 540738 [id="node_540738" labelType="html" label="ShuffledRowRDD [540738] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412086 { id="cluster_1412086"; isCluster="true"; label="WholeStageCodegen (22)"; 540739 [id="node_540739" labelType="html" label="MapPartitionsRDD [540739] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411959 { id="cluster_1411959"; isCluster="true"; label="WholeStageCodegen (23)"; 540740 [id="node_540740" labelType="html" label="ZippedPartitionsRDD2 [540740] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540741 [id="node_540741" labelType="html" label="MapPartitionsRDD [540741] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411958 { id="cluster_1411958"; isCluster="true"; label="DeserializeToObject"; 540742 [id="node_540742" labelType="html" label="MapPartitionsRDD [540742] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411957 { id="cluster_1411957"; isCluster="true"; label="MapPartitions"; 540743 [id="node_540743" labelType="html" label="MapPartitionsRDD [540743] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411935 { id="cluster_1411935"; isCluster="true"; label="WholeStageCodegen (26)"; 540744 [id="node_540744" labelType="html" label="MapPartitionsRDD [540744] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411934 { id="cluster_1411934"; isCluster="true"; label="DeserializeToObject"; 540745 [id="node_540745" labelType="html" label="MapPartitionsRDD [540745] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412102 { id="cluster_1412102"; isCluster="true"; label="mapPartitions"; 540747 [id="node_540747" labelType="html" label="MapPartitionsRDD [540747] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412103 { id="cluster_1412103"; isCluster="true"; label="mapPartitions"; 540748 [id="node_540748" labelType="html" label="MapPartitionsRDD [540748] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412216 { id="cluster_1412216"; isCluster="true"; label="Scan"; 540749 [id="node_540749" labelType="html" label="MapPartitionsRDD [540749] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412210 { id="cluster_1412210"; isCluster="true"; label="WholeStageCodegen (1)"; 540750 [id="node_540750" labelType="html" label="MapPartitionsRDD [540750] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412209 { id="cluster_1412209"; isCluster="true"; label="InMemoryTableScan"; 540751 [id="node_540751" labelType="html" label="MapPartitionsRDD [540751] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540752 [id="node_540752" labelType="html" label="*(1) Generate explode(prodPlantResults#8718872), false, [prodPlantResults#8718879]\n+- *(1) Project [prodPlantResults#8718872]\n +- *(1) Filter ((size(prodPlantResults#8718872, true) > 0) AND isnotnull(prodPlantResults#8718872))\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... [540752] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540753 [id="node_540753" labelType="html" label="MapPartitionsRDD [540753] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540754 [id="node_540754" labelType="html" label="MapPartitionsRDD [540754] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540755 [id="node_540755" labelType="html" label="MapPartitionsRDD [540755] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412208 { id="cluster_1412208"; isCluster="true"; label="Project"; 540756 [id="node_540756" labelType="html" label="MapPartitionsRDD [540756] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412223 { id="cluster_1412223"; isCluster="true"; label="InMemoryTableScan"; 540757 [id="node_540757" labelType="html" label="MapPartitionsRDD [540757] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540758 [id="node_540758" labelType="html" label="MapPartitionsRDD [540758] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540759 [id="node_540759" labelType="html" label="MapPartitionsRDD [540759] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412218 { id="cluster_1412218"; isCluster="true"; label="WholeStageCodegen (1)"; 540760 [id="node_540760" labelType="html" label="MapPartitionsRDD [540760] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412217 { id="cluster_1412217"; isCluster="true"; label="Project"; 540761 [id="node_540761" labelType="html" label="MapPartitionsRDD [540761] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412230 { id="cluster_1412230"; isCluster="true"; label="InMemoryTableScan"; 540762 [id="node_540762" labelType="html" label="MapPartitionsRDD [540762] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540763 [id="node_540763" labelType="html" label="MapPartitionsRDD [540763] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540764 [id="node_540764" labelType="html" label="MapPartitionsRDD [540764] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412225 { id="cluster_1412225"; isCluster="true"; label="WholeStageCodegen (2)"; 540765 [id="node_540765" labelType="html" label="MapPartitionsRDD [540765] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412224 { id="cluster_1412224"; isCluster="true"; label="Project"; 540766 [id="node_540766" labelType="html" label="MapPartitionsRDD [540766] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412207 { id="cluster_1412207"; isCluster="true"; label="Union"; 540767 [id="node_540767" labelType="html" label="UnionRDD [540767] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412206 { id="cluster_1412206"; isCluster="true"; label="Exchange"; 540768 [id="node_540768" labelType="html" label="MapPartitionsRDD [540768] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540724->540725; 540738->540739; 540725->540740; 540739->540740; 540740->540741; 540741->540742; 540742->540743; 540743->540744; 540744->540745; 540745->540746; 540746->540747; 540747->540748; 540748->540749; 540749->540750; 540750->540751; 540751->540752; 540752->540753; 540753->540754; 540754->540755; 540755->540756; 540752->540757; 540757->540758; 540758->540759; 540759->540760; 540760->540761; 540752->540762; 540762->540763; 540763->540764; 540764->540765; 540765->540766; 540756->540767; 540761->540767; 540766->540767; 540767->540768; }

540723,540724

540737,540738

540748

540752

digraph G { id="graph_241625"; subgraph graph_stage_241625 { id="graph_stage_241625"; isCluster="true"; label="Stage 241625 (skipped)"; subgraph cluster_1411767 { id="cluster_1411767"; isCluster="true"; label="Exchange"; 540586 [id="node_540586" labelType="html" label="ShuffledRowRDD [540586] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411766 { id="cluster_1411766"; isCluster="true"; label="InMemoryTableScan"; 540587 [id="node_540587" labelType="html" label="MapPartitionsRDD [540587] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540588 [id="node_540588" labelType="html" label="Exchange hashpartitioning(product#8398783, plant#8398784, 30), REPARTITION_BY_NUM, [plan_id=36546947]\n+- *(1) Scan ExistingRDD[shardId#8398780,worklistShardItemId#8398781L,version#8398782,product#8398783,plant#8398784,periodStart#8398785,periodEnd#8398786,qty#8398787]\n [540588] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412240 { id="cluster_1412240"; isCluster="true"; label="InMemoryTableScan"; 540771 [id="node_540771" labelType="html" label="MapPartitionsRDD [540771] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540772 [id="node_540772" labelType="html" label="MapPartitionsRDD [540772] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540773 [id="node_540773" labelType="html" label="MapPartitionsRDD [540773] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412236 { id="cluster_1412236"; isCluster="true"; label="WholeStageCodegen (4)"; 540774 [id="node_540774" labelType="html" label="MapPartitionsRDD [540774] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412235 { id="cluster_1412235"; isCluster="true"; label="Exchange"; 540775 [id="node_540775" labelType="html" label="MapPartitionsRDD [540775] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540586->540587; 540587->540588; 540588->540771; 540771->540772; 540772->540773; 540773->540774; 540774->540775; }

540585,540586

540588

digraph G { id="graph_241626"; subgraph graph_stage_241626 { id="graph_stage_241626"; isCluster="true"; label="Stage 241626 (skipped)"; subgraph cluster_1412206 { id="cluster_1412206"; isCluster="true"; label="Exchange"; 540769 [id="node_540769" labelType="html" label="ShuffledRowRDD [540769] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412203 { id="cluster_1412203"; isCluster="true"; label="WholeStageCodegen (3)"; 540770 [id="node_540770" labelType="html" label="MapPartitionsRDD [540770] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412235 { id="cluster_1412235"; isCluster="true"; label="Exchange"; 540776 [id="node_540776" labelType="html" label="ShuffledRowRDD [540776] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412232 { id="cluster_1412232"; isCluster="true"; label="WholeStageCodegen (5)"; 540777 [id="node_540777" labelType="html" label="MapPartitionsRDD [540777] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412198 { id="cluster_1412198"; isCluster="true"; label="WholeStageCodegen (6)"; 540778 [id="node_540778" labelType="html" label="ZippedPartitionsRDD2 [540778] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540779 [id="node_540779" labelType="html" label="MapPartitionsRDD [540779] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412197 { id="cluster_1412197"; isCluster="true"; label="SortAggregate"; 540780 [id="node_540780" labelType="html" label="MapPartitionsRDD [540780] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412196 { id="cluster_1412196"; isCluster="true"; label="Exchange"; 540781 [id="node_540781" labelType="html" label="MapPartitionsRDD [540781] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540769->540770; 540776->540777; 540770->540778; 540777->540778; 540778->540779; 540779->540780; 540780->540781; }

540768,540769

540775,540776

digraph G { id="graph_241627"; subgraph graph_stage_241627 { id="graph_stage_241627"; isCluster="true"; label="Stage 241627 (skipped)"; subgraph cluster_1412196 { id="cluster_1412196"; isCluster="true"; label="Exchange"; 540782 [id="node_540782" labelType="html" label="ShuffledRowRDD [540782] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412193 { id="cluster_1412193"; isCluster="true"; label="WholeStageCodegen (7)"; 540783 [id="node_540783" labelType="html" label="MapPartitionsRDD [540783] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412192 { id="cluster_1412192"; isCluster="true"; label="SortAggregate"; 540784 [id="node_540784" labelType="html" label="MapPartitionsRDD [540784] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412191 { id="cluster_1412191"; isCluster="true"; label="InMemoryTableScan"; 540785 [id="node_540785" labelType="html" label="MapPartitionsRDD [540785] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540786 [id="node_540786" labelType="html" label="SortAggregate(key=[demandChannel#8718905, shardId#8398780, qty#8718925, worklistShardItemId#8398781L, demandStream#8718906], functions=[first(kpis#8718934, false)], output=[shardId#8398780, worklistShardItemId#8398781L, qty#8718925, demandChannel#8718905, demandStream#8718906, kpis#8719047])\n+- *(7) Sort [demandChannel#8718905 ASC NULLS FIRST, shardId#8398780 ASC NULLS FIRST, qty#8718925 ASC NULLS FIRST, worklistShardItemId#8398781L ASC NULLS FIRST, demandStream#8718906 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#8718905, shardId#8398780, qty#8718925, worklistShardItemId#8398781L, demandStream#8718906, 30), ENSURE_REQUIREMENTS, [plan_id=36548095]\n +- SortAggregate(key=[demandChannel#8718905, shardId#8398780, knownfloatingpointnormalized(normalizenanandzero(qty#8718925)) AS qty#8718925, worklistShardItemId#8398781L, demandStream#8718906], functions=[partial_first(kpis#8718934, false)], output=[demandChannel#8718905, shardId#8398780, qty#8718925, worklistShardItemId#8398781L... [540786] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412303 { id="cluster_1412303"; isCluster="true"; label="InMemoryTableScan"; 540793 [id="node_540793" labelType="html" label="MapPartitionsRDD [540793] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540794 [id="node_540794" labelType="html" label="MapPartitionsRDD [540794] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540795 [id="node_540795" labelType="html" label="MapPartitionsRDD [540795] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412300 { id="cluster_1412300"; isCluster="true"; label="WholeStageCodegen (1)"; 540796 [id="node_540796" labelType="html" label="MapPartitionsRDD [540796] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412299 { id="cluster_1412299"; isCluster="true"; label="Exchange"; 540797 [id="node_540797" labelType="html" label="MapPartitionsRDD [540797] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540782->540783; 540783->540784; 540784->540785; 540785->540786; 540786->540793; 540793->540794; 540794->540795; 540795->540796; 540796->540797; }

540781,540782

540786

digraph G { id="graph_241628"; subgraph graph_stage_241628 { id="graph_stage_241628"; isCluster="true"; label="Stage 241628 (skipped)"; subgraph cluster_1411767 { id="cluster_1411767"; isCluster="true"; label="Exchange"; 540586 [id="node_540586" labelType="html" label="ShuffledRowRDD [540586] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411766 { id="cluster_1411766"; isCluster="true"; label="InMemoryTableScan"; 540587 [id="node_540587" labelType="html" label="MapPartitionsRDD [540587] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540588 [id="node_540588" labelType="html" label="Exchange hashpartitioning(product#8398783, plant#8398784, 30), REPARTITION_BY_NUM, [plan_id=36546947]\n+- *(1) Scan ExistingRDD[shardId#8398780,worklistShardItemId#8398781L,version#8398782,product#8398783,plant#8398784,periodStart#8398785,periodEnd#8398786,qty#8398787]\n [540588] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412314 { id="cluster_1412314"; isCluster="true"; label="InMemoryTableScan"; 540800 [id="node_540800" labelType="html" label="MapPartitionsRDD [540800] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540801 [id="node_540801" labelType="html" label="MapPartitionsRDD [540801] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540802 [id="node_540802" labelType="html" label="MapPartitionsRDD [540802] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412310 { id="cluster_1412310"; isCluster="true"; label="WholeStageCodegen (3)"; 540803 [id="node_540803" labelType="html" label="MapPartitionsRDD [540803] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412309 { id="cluster_1412309"; isCluster="true"; label="Exchange"; 540804 [id="node_540804" labelType="html" label="MapPartitionsRDD [540804] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540586->540587; 540587->540588; 540588->540800; 540800->540801; 540801->540802; 540802->540803; 540803->540804; }

540585,540586

540588

digraph G { id="graph_241629"; subgraph graph_stage_241629 { id="graph_stage_241629"; isCluster="true"; label="Stage 241629"; subgraph cluster_1412299 { id="cluster_1412299"; isCluster="true"; label="Exchange"; 540798 [id="node_540798" labelType="html" label="ShuffledRowRDD [540798] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412296 { id="cluster_1412296"; isCluster="true"; label="WholeStageCodegen (2)"; 540799 [id="node_540799" labelType="html" label="MapPartitionsRDD [540799] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412309 { id="cluster_1412309"; isCluster="true"; label="Exchange"; 540805 [id="node_540805" labelType="html" label="ShuffledRowRDD [540805] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412305 { id="cluster_1412305"; isCluster="true"; label="WholeStageCodegen (4)"; 540806 [id="node_540806" labelType="html" label="MapPartitionsRDD [540806] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412292 { id="cluster_1412292"; isCluster="true"; label="WholeStageCodegen (5)"; 540807 [id="node_540807" labelType="html" label="ZippedPartitionsRDD2 [540807] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540808 [id="node_540808" labelType="html" label="MapPartitionsRDD [540808] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412291 { id="cluster_1412291"; isCluster="true"; label="InMemoryTableScan"; 540809 [id="node_540809" labelType="html" label="MapPartitionsRDD [540809] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540810 [id="node_540810" labelType="html" label="*(5) Project [shardId#8398780, worklistShardItemId#8398781L, version#8719396, qty#8718925, demandChannel#8718905, demandStream#8718906, kpis#8718934]\n+- *(5) SortMergeJoin [shardId#8398780, worklistShardItemId#8398781L], [shardId#8719401, worklistShardItemId#8719402L], Inner\n :- *(2) Sort [shardId#8398780 ASC NULLS FIRST, worklistShardItemId#8398781L ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(shardId#8398780, worklistShardItemId#8398781L, 30), ENSURE_REQUIREMENTS, [plan_id=36548203]\n : +- *(1) Filter (isnotnull(shardId#8398780) AND isnotnull(worklistShardItemId#8398781L))\n : +- InMemoryTableScan [shardId#8398780, worklistShardItemId#8398781L, qty#8718925, demandChannel#8718905, demandStream#8718906, kpis#8718934], [isnotnull(shardId#8398780), isnotnull(worklistShardItemId#8398781L)]\n : +- InMemoryRelation [shardId#8398780, worklistShardItemId#8398781L, qty#8718925, demandChannel#8718905, demandStream#8718906, kpis#8718934], StorageLevel(disk, memory, 2 rep... [540810] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1412345 { id="cluster_1412345"; isCluster="true"; label="InMemoryTableScan"; 540819 [id="node_540819" labelType="html" label="MapPartitionsRDD [540819] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540820 [id="node_540820" labelType="html" label="MapPartitionsRDD [540820] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540821 [id="node_540821" labelType="html" label="MapPartitionsRDD [540821] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540798->540799; 540805->540806; 540799->540807; 540806->540807; 540807->540808; 540808->540809; 540809->540810; 540810->540819; 540819->540820; 540820->540821; }

540797,540798

540804,540805

540810

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
241629	tenants-pool-506	stream-10000000540-2 id = 1ee1bc26-de60-48c1-be7f-8f91352c23f8 runId = e97f90ad-57e2-4862-afd3-46c7c1a84cab batch = 32 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/09/01 14:16:19	0.9 s	30/30	10.7 MiB	2.7 MiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

241629

tenants-pool-506

stream-10000000540-2 id = 1ee1bc26-de60-48c1-be7f-8f91352c23f8 runId = e97f90ad-57e2-4862-afd3-46c7c1a84cab batch = 32 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/09/01 14:16:19

0.9 s

30/30

10.7 MiB

2.7 MiB

Page:

Skipped Stages (15)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
241628	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
241627	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
241626	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
241625	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
241624	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
241623	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
241622	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
241621	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
241620	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
241619	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
241618	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
241617	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
241616	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
241615	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
241614	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: