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>task commit time: 1 ms<br>number of written files: 1<br>job commit time: 13 ms<br>number of output rows: 76<br>number of dynamic part: 0<br>written output: 13.6 KiB"];
1 [labelType="html" label="<br><b>WriteFiles</b><br><br>"];
2 [labelType="html" label="<br><b>Coalesce</b><br><br>"];
subgraph cluster3 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 284 ms";
4 [labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 76"];
}
1->0;
2->1;
4->2;
}
5
Execute InsertIntoHadoopFsRelationCommand file:/data/output/export/csv/9d3992e2-8826-4020-8b31-da792b87dc4b, false, CSV, [path=file:///data/output/export/csv/9d3992e2-8826-4020-8b31-da792b87dc4b, nullValue=, ignoreLeadingWhiteSpace=true, quoteAll=false, sep=;, quote=", emptyValue=, ignoreTrailingWhiteSpace=false, escape=\, charset=UTF-8, lineSep=
, header=true], ErrorIfExists, [ROW_NUMBER, LigneType, IdExpand, IdDossier-Full, FINESS ePMSI, FINESS géographique, immatriculation assuré, Clé du n° immatriculation, Rang de bénéficiaire, N° d'entrée, N° immatriculation individuel, Clé du n° immatriculation individuel, Date de début de séjour, Code référence LPP, Quantité, Tarif référence LPP ou Prix Unitaire sur devis, Montant total facturé, Prix d'achat unitaire, Montant unitaire de l'écart indemnisable, Montant total de l'écart indemnisable, Numéro de facture, Taille Ligne P]
WriteFiles
Coalesce 1
Scan ExistingRDD[ROW_NUMBER#9205,LigneType#9206,IdExpand#9207,IdDossier-Full#9208,FINESS ePMSI#9209,FINESS géographique#9210,immatriculation assuré#9211,Clé du n° immatriculation#9212,Rang de bénéficiaire#9213,N° d'entrée#9214,N° immatriculation individuel#9215,Clé du n° immatriculation individuel#9216,Date de début de séjour#9217,Code référence LPP#9218,Quantité#9219,Tarif référence LPP ou Prix Unitaire sur devis#9220,Montant total facturé#9221,Prix d'achat unitaire#9222,Montant unitaire de l'écart indemnisable#9223,Montant total de l'écart indemnisable#9224,Numéro de facture#9225,Taille Ligne P#9226]
== Physical Plan ==
Execute InsertIntoHadoopFsRelationCommand (4)
+- WriteFiles (3)
+- Coalesce (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [22]: [ROW_NUMBER#9205, LigneType#9206, IdExpand#9207, IdDossier-Full#9208, FINESS ePMSI#9209, FINESS géographique#9210, immatriculation assuré#9211, Clé du n° immatriculation#9212, Rang de bénéficiaire#9213, N° d'entrée#9214, N° immatriculation individuel#9215, Clé du n° immatriculation individuel#9216, Date de début de séjour#9217, Code référence LPP#9218, Quantité#9219, Tarif référence LPP ou Prix Unitaire sur devis#9220, Montant total facturé#9221, Prix d'achat unitaire#9222, Montant unitaire de l'écart indemnisable#9223, Montant total de l'écart indemnisable#9224, Numéro de facture#9225, Taille Ligne P#9226]
Arguments: [ROW_NUMBER#9205, LigneType#9206, IdExpand#9207, IdDossier-Full#9208, FINESS ePMSI#9209, FINESS géographique#9210, immatriculation assuré#9211, Clé du n° immatriculation#9212, Rang de bénéficiaire#9213, N° d'entrée#9214, N° immatriculation individuel#9215, Clé du n° immatriculation individuel#9216, Date de début de séjour#9217, Code référence LPP#9218, Quantité#9219, Tarif référence LPP ou Prix Unitaire sur devis#9220, Montant total facturé#9221, Prix d'achat unitaire#9222, Montant unitaire de l'écart indemnisable#9223, Montant total de l'écart indemnisable#9224, Numéro de facture#9225, Taille Ligne P#9226], MapPartitionsRDD[136] at createDataFrame at AbsExportExecutor.java:55, ExistingRDD, UnknownPartitioning(0)
(2) Coalesce
Input [22]: [ROW_NUMBER#9205, LigneType#9206, IdExpand#9207, IdDossier-Full#9208, FINESS ePMSI#9209, FINESS géographique#9210, immatriculation assuré#9211, Clé du n° immatriculation#9212, Rang de bénéficiaire#9213, N° d'entrée#9214, N° immatriculation individuel#9215, Clé du n° immatriculation individuel#9216, Date de début de séjour#9217, Code référence LPP#9218, Quantité#9219, Tarif référence LPP ou Prix Unitaire sur devis#9220, Montant total facturé#9221, Prix d'achat unitaire#9222, Montant unitaire de l'écart indemnisable#9223, Montant total de l'écart indemnisable#9224, Numéro de facture#9225, Taille Ligne P#9226]
Arguments: 1
(3) WriteFiles
Input [22]: [ROW_NUMBER#9205, LigneType#9206, IdExpand#9207, IdDossier-Full#9208, FINESS ePMSI#9209, FINESS géographique#9210, immatriculation assuré#9211, Clé du n° immatriculation#9212, Rang de bénéficiaire#9213, N° d'entrée#9214, N° immatriculation individuel#9215, Clé du n° immatriculation individuel#9216, Date de début de séjour#9217, Code référence LPP#9218, Quantité#9219, Tarif référence LPP ou Prix Unitaire sur devis#9220, Montant total facturé#9221, Prix d'achat unitaire#9222, Montant unitaire de l'écart indemnisable#9223, Montant total de l'écart indemnisable#9224, Numéro de facture#9225, Taille Ligne P#9226]
(4) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/export/csv/9d3992e2-8826-4020-8b31-da792b87dc4b, false, CSV, [path=file:///data/output/export/csv/9d3992e2-8826-4020-8b31-da792b87dc4b, nullValue=, ignoreLeadingWhiteSpace=true, quoteAll=false, sep=;, quote=", emptyValue=, ignoreTrailingWhiteSpace=false, escape=\, charset=UTF-8, lineSep=
, header=true], ErrorIfExists, [ROW_NUMBER, LigneType, IdExpand, IdDossier-Full, FINESS ePMSI, FINESS géographique, immatriculation assuré, Clé du n° immatriculation, Rang de bénéficiaire, N° d'entrée, N° immatriculation individuel, Clé du n° immatriculation individuel, Date de début de séjour, Code référence LPP, Quantité, Tarif référence LPP ou Prix Unitaire sur devis, Montant total facturé, Prix d'achat unitaire, Montant unitaire de l'écart indemnisable, Montant total de l'écart indemnisable, Numéro de facture, Taille Ligne P]