Show the Stage ID and Task ID that corresponds to the max metric
digraph G {
0 [labelType="html" label="<b>Execute InsertIntoHadoopFsRelationCommand</b><br><br>number of written files: 1<br>written output: 11.4 KiB<br>number of output rows: 2,389<br>number of dynamic part: 0"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 905 ms";
2 [labelType="html" label="<b>Scan JDBCRelation(( SELECT `jwh`, `ye`, sum(`dl`) dl FROM(\r<br> \tSELECT jwh,mon ye,dl from t_report_electricity2_2 WHERE ye='2023'\r<br> \tUNION ALL\r<br> \tSELECT `jwh`, '1\u6708' as ye, `dl` from adjust_the_power \r<br> \tWHERE statistical_year= '2023' and `month`<>'\u4EE5\u524D\u5E74\u5EA6\u8C03\u6574\u7535\u91CF'\r<br> \tUNION ALL\r<br> \tSELECT jwh,'1\u6708' ye,sum(dl)dl from t_report_electricity2_2 \r<br> \tWHERE ye<'2023' GROUP BY jwh\r<br> \tUNION ALL\r<br> \tSELECT `jwh`, 'yqdndl' as ye, sum(`dl`)dl from adjust_the_power \r<br> \tWHERE statistical_year<\t'2023' GROUP BY jwh\r<br> )t1\r<br> GROUP BY `jwh`, `ye` <br> ) as T) [numPartitions=1] </b><br><br>number of output rows: 2,389"];
}
2->0;
}
3
Execute InsertIntoHadoopFsRelationCommand file:/data/Smartbi_CentOS_x86_CN_V10.5.8/SmartbiEngine/data/event/Iff808081018a6bdd6bdd9c18018ab1936679017e/56c9662ac0a6582876ad56e090da8939/dataset, false, Parquet, [path=file:///data/Smartbi_CentOS_x86_CN_V10.5.8/SmartbiEngine/data/event/Iff808081018a6bdd6bdd9c18018ab1936679017e/56c9662ac0a6582876ad56e090da8939/dataset], Overwrite, [jwh, ye, dl]
Scan JDBCRelation(( SELECT `jwh`, `ye`, sum(`dl`) dl FROM(
SELECT jwh,mon ye,dl from t_report_electricity2_2 WHERE ye='2023'
UNION ALL
SELECT `jwh`, '1月' as ye, `dl` from adjust_the_power
WHERE statistical_year= '2023' and `month`<>'以前年度调整电量'
UNION ALL
SELECT jwh,'1月' ye,sum(dl)dl from t_report_electricity2_2
WHERE ye<'2023' GROUP BY jwh
UNION ALL
SELECT `jwh`, 'yqdndl' as ye, sum(`dl`)dl from adjust_the_power
WHERE statistical_year< '2023' GROUP BY jwh
)t1
GROUP BY `jwh`, `ye`
) as T) [numPartitions=1] [jwh#10,ye#11,dl#12] PushedFilters: [], ReadSchema: struct<jwh:string,ye:string,dl:double>
== Physical Plan ==
Execute InsertIntoHadoopFsRelationCommand (2)
+- * Scan JDBCRelation(( SELECT `jwh`, `ye`, sum(`dl`) dl FROM(
SELECT jwh,mon ye,dl from t_report_electricity2_2 WHERE ye='2023'
UNION ALL
SELECT `jwh`, '1月' as ye, `dl` from adjust_the_power
WHERE statistical_year= '2023' and `month`<>'以前年度调整电量'
UNION ALL
SELECT jwh,'1月' ye,sum(dl)dl from t_report_electricity2_2
WHERE ye<'2023' GROUP BY jwh
UNION ALL
SELECT `jwh`, 'yqdndl' as ye, sum(`dl`)dl from adjust_the_power
WHERE statistical_year< '2023' GROUP BY jwh
)t1
GROUP BY `jwh`, `ye`
) as T) [numPartitions=1] (1)
(1) Scan JDBCRelation(( SELECT `jwh`, `ye`, sum(`dl`) dl FROM(
SELECT jwh,mon ye,dl from t_report_electricity2_2 WHERE ye='2023'
UNION ALL
SELECT `jwh`, '1月' as ye, `dl` from adjust_the_power
WHERE statistical_year= '2023' and `month`<>'以前年度调整电量'
UNION ALL
SELECT jwh,'1月' ye,sum(dl)dl from t_report_electricity2_2
WHERE ye<'2023' GROUP BY jwh
UNION ALL
SELECT `jwh`, 'yqdndl' as ye, sum(`dl`)dl from adjust_the_power
WHERE statistical_year< '2023' GROUP BY jwh
)t1
GROUP BY `jwh`, `ye`
) as T) [numPartitions=1] [codegen id : 1]
Output [3]: [jwh#10, ye#11, dl#12]
ReadSchema: struct<jwh:string,ye:string,dl:double>
(2) Execute InsertIntoHadoopFsRelationCommand
Input [3]: [jwh#10, ye#11, dl#12]
Arguments: file:/data/Smartbi_CentOS_x86_CN_V10.5.8/SmartbiEngine/data/event/Iff808081018a6bdd6bdd9c18018ab1936679017e/56c9662ac0a6582876ad56e090da8939/dataset, false, Parquet, [path=file:///data/Smartbi_CentOS_x86_CN_V10.5.8/SmartbiEngine/data/event/Iff808081018a6bdd6bdd9c18018ab1936679017e/56c9662ac0a6582876ad56e090da8939/dataset], Overwrite, [jwh, ye, dl]