Show the Stage ID and Task ID that corresponds to the max metric
digraph G {
0 [labelType="html" label="<br><b>AdaptiveSparkPlan</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (2)\n \nduration: 0 ms";
2 [labelType="html" label="<br><b>Project</b><br><br>"];
3 [labelType="html" label="<b>HashAggregate</b><br><br>time in aggregation build: 0 ms<br>number of output rows: 1"];
}
4 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 3<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>3 ms (0 ms, 0 ms, 2 ms (stage 876.0: task 1177))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 3<br>local bytes read: 170.0 B<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 3<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size total (min, med, max (stageId: taskId))<br>72.0 B (24.0 B, 24.0 B, 24.0 B (stage 876.0: task 1178))<br>local merged bytes read: 0.0 B<br>number of partitions: 1<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>170.0 B (56.0 B, 57.0 B, 57.0 B (stage 876.0: task 1178))"];
subgraph cluster5 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n48 ms (6 ms, 7 ms, 35 ms (stage 876.0: task 1177))";
6 [labelType="html" label="<b>HashAggregate</b><br><br>time in aggregation build total (min, med, max (stageId: taskId))<br>46 ms (6 ms, 7 ms, 33 ms (stage 876.0: task 1177))<br>number of output rows: 3"];
7 [labelType="html" label="<br><b>Project</b><br><br>"];
8 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 7"];
9 [labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 20,000<br>number of input batches: 5"];
}
10 [labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 3<br>scan time total (min, med, max (stageId: taskId))<br>39 ms (6 ms, 7 ms, 26 ms (stage 876.0: task 1177))<br>metadata time: 0 ms<br>size of files read: 496.9 KiB<br>number of output rows: 20,000"];
2->0;
3->2;
4->3;
6->4;
7->6;
8->7;
9->8;
10->9;
}
11
AdaptiveSparkPlan isFinalPlan=true
Project [COL_D5F3070D_302E_4C75_81DA_88629D51A748#143125L, COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#143127L, str_concat(array(Nb RSA PIE Année n : , bigint_to_str(COL_D5F3070D_302E_4C75_81DA_88629D51A748#143125L), , Nb RSA Année n -1 : , bigint_to_str(COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#143127L))) AS COL_5EDF5460_6750_4C31_8D3F_78F6BC887AA9#143503]
Project [COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#142206 AS COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#142580, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#142207 AS COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#142581]
Filter (((COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#142201 <=> 350000055) AND (COL_B69B2310_3A87_437C_B292_E2D12FC12449#142214 <=> 2025-07)) AND (COL_D6826CBC_1D7A_47AB_846E_D442A882445E#142205 <=> typsejb))