SP1 - Details for Job 6842

Status: SUCCEEDED
Submitted: 2026/10/20 09:17:43
Duration: 5 s
Associated SQL Query: 4447
Job Group: 6b02a51b-a264-4193-963b-fdc2adfe1f48
Completed Stages: 1
Skipped Stages: 18

Enable zooming

digraph G { subgraph clusterstage_13684 { label="Stage 13684 (skipped)"; subgraph cluster88679 { label="Scan csv "; 37765 [labelType="html" label="FileScanRDD [37765] parquet at PersistJob.java:35"]; 37766 [labelType="html" label="MapPartitionsRDD [37766] parquet at PersistJob.java:35"]; } subgraph cluster88676 { label="WholeStageCodegen (5)"; 37767 [labelType="html" label="MapPartitionsRDD [37767] parquet at PersistJob.java:35"]; } subgraph cluster88675 { label="ObjectHashAggregate"; 37768 [labelType="html" label="MapPartitionsRDD [37768] parquet at PersistJob.java:35"]; } subgraph cluster88674 { label="Exchange"; 37769 [labelType="html" label="MapPartitionsRDD [37769] parquet at PersistJob.java:35"]; } } 37765->37766; 37766->37767; 37767->37768; 37768->37769; }

digraph G { subgraph clusterstage_13685 { label="Stage 13685 (skipped)"; subgraph cluster88655 { label="Scan csv "; 37749 [labelType="html" label="FileScanRDD [37749] parquet at PersistJob.java:35"]; 37750 [labelType="html" label="MapPartitionsRDD [37750] parquet at PersistJob.java:35"]; } subgraph cluster88652 { label="WholeStageCodegen (1)"; 37751 [labelType="html" label="MapPartitionsRDD [37751] parquet at PersistJob.java:35"]; } subgraph cluster88651 { label="ObjectHashAggregate"; 37752 [labelType="html" label="MapPartitionsRDD [37752] parquet at PersistJob.java:35"]; } subgraph cluster88650 { label="Exchange"; 37753 [labelType="html" label="MapPartitionsRDD [37753] parquet at PersistJob.java:35"]; } } 37749->37750; 37750->37751; 37751->37752; 37752->37753; }

digraph G { subgraph clusterstage_13686 { label="Stage 13686 (skipped)"; subgraph cluster88691 { label="Scan csv "; 37775 [labelType="html" label="FileScanRDD [37775] parquet at PersistJob.java:35"]; 37776 [labelType="html" label="MapPartitionsRDD [37776] parquet at PersistJob.java:35"]; } subgraph cluster88688 { label="WholeStageCodegen (7)"; 37777 [labelType="html" label="MapPartitionsRDD [37777] parquet at PersistJob.java:35"]; } subgraph cluster88687 { label="ObjectHashAggregate"; 37778 [labelType="html" label="MapPartitionsRDD [37778] parquet at PersistJob.java:35"]; } subgraph cluster88686 { label="Exchange"; 37779 [labelType="html" label="MapPartitionsRDD [37779] parquet at PersistJob.java:35"]; } } 37775->37776; 37776->37777; 37777->37778; 37778->37779; }

digraph G { subgraph clusterstage_13687 { label="Stage 13687 (skipped)"; subgraph cluster88685 { label="Scan csv "; 37770 [labelType="html" label="FileScanRDD [37770] parquet at PersistJob.java:35"]; 37771 [labelType="html" label="MapPartitionsRDD [37771] parquet at PersistJob.java:35"]; } subgraph cluster88682 { label="WholeStageCodegen (6)"; 37772 [labelType="html" label="MapPartitionsRDD [37772] parquet at PersistJob.java:35"]; } subgraph cluster88681 { label="ObjectHashAggregate"; 37773 [labelType="html" label="MapPartitionsRDD [37773] parquet at PersistJob.java:35"]; } subgraph cluster88680 { label="Exchange"; 37774 [labelType="html" label="MapPartitionsRDD [37774] parquet at PersistJob.java:35"]; } } 37770->37771; 37771->37772; 37772->37773; 37773->37774; }

digraph G { subgraph clusterstage_13688 { label="Stage 13688 (skipped)"; subgraph cluster88738 { label="Scan csv "; 37811 [labelType="html" label="FileScanRDD [37811] parquet at PersistJob.java:35"]; 37812 [labelType="html" label="MapPartitionsRDD [37812] parquet at PersistJob.java:35"]; } subgraph cluster88735 { label="WholeStageCodegen (15)"; 37813 [labelType="html" label="MapPartitionsRDD [37813] parquet at PersistJob.java:35"]; } subgraph cluster88734 { label="Exchange"; 37814 [labelType="html" label="MapPartitionsRDD [37814] parquet at PersistJob.java:35"]; } } 37811->37812; 37812->37813; 37813->37814; }

digraph G { subgraph clusterstage_13689 { label="Stage 13689 (skipped)"; subgraph cluster88941 { label="Scan parquet "; 37939 [labelType="html" label="FileScanRDD [37939] parquet at PersistJob.java:35"]; 37940 [labelType="html" label="MapPartitionsRDD [37940] parquet at PersistJob.java:35"]; } subgraph cluster88936 { label="WholeStageCodegen (46)"; 37941 [labelType="html" label="MapPartitionsRDD [37941] parquet at PersistJob.java:35"]; } subgraph cluster88946 { label="Scan csv "; 37942 [labelType="html" label="FileScanRDD [37942] parquet at PersistJob.java:35"]; 37943 [labelType="html" label="MapPartitionsRDD [37943] parquet at PersistJob.java:35"]; } subgraph cluster88942 { label="WholeStageCodegen (47)"; 37944 [labelType="html" label="MapPartitionsRDD [37944] parquet at PersistJob.java:35"]; } subgraph cluster88935 { label="CartesianProduct"; 37945 [labelType="html" label="UnsafeCartesianRDD [37945] parquet at PersistJob.java:35"]; 37946 [labelType="html" label="MapPartitionsRDD [37946] parquet at PersistJob.java:35"]; } subgraph cluster88932 { label="WholeStageCodegen (48)"; 37947 [labelType="html" label="MapPartitionsRDD [37947] parquet at PersistJob.java:35"]; } subgraph cluster88951 { label="Exchange"; 37948 [labelType="html" label="ShuffledRowRDD [37948] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88947 { label="WholeStageCodegen (49)"; 37949 [labelType="html" label="MapPartitionsRDD [37949] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88931 { label="CartesianProduct"; 37950 [labelType="html" label="UnsafeCartesianRDD [37950] [Unordered] parquet at PersistJob.java:35"]; 37951 [labelType="html" label="MapPartitionsRDD [37951] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88928 { label="WholeStageCodegen (50)"; 37952 [labelType="html" label="MapPartitionsRDD [37952] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88927 { label="Exchange"; 37953 [labelType="html" label="MapPartitionsRDD [37953] [Unordered] parquet at PersistJob.java:35"]; } } 37939->37940; 37940->37941; 37942->37943; 37943->37944; 37941->37945; 37944->37945; 37945->37946; 37946->37947; 37948->37949; 37947->37950; 37949->37950; 37950->37951; 37951->37952; 37952->37953; }

37814,37948

digraph G { subgraph clusterstage_13690 { label="Stage 13690 (skipped)"; subgraph cluster88976 { label="AQEShuffleRead"; 37961 [labelType="html" label="ShuffledRowRDD [37961] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88973 { label="WholeStageCodegen (57)"; 37962 [labelType="html" label="MapPartitionsRDD [37962] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88972 { label="Window"; 37963 [labelType="html" label="MapPartitionsRDD [37963] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88968 { label="WholeStageCodegen (58)"; 37964 [labelType="html" label="MapPartitionsRDD [37964] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88967 { label="Exchange"; 37968 [labelType="html" label="MapPartitionsRDD [37968] [Unordered] parquet at PersistJob.java:35"]; } } 37961->37962; 37962->37963; 37963->37964; 37964->37968; }

37953,37961

digraph G { subgraph clusterstage_13691 { label="Stage 13691 (skipped)"; subgraph cluster89007 { label="AQEShuffleRead"; 37969 [labelType="html" label="ShuffledRowRDD [37969] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89004 { label="WholeStageCodegen (59)"; 37970 [labelType="html" label="MapPartitionsRDD [37970] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89003 { label="Exchange"; 37971 [labelType="html" label="MapPartitionsRDD [37971] [Unordered] parquet at PersistJob.java:35"]; } } 37969->37970; 37970->37971; }

37968,37969

digraph G { subgraph clusterstage_13692 { label="Stage 13692 (skipped)"; subgraph cluster88715 { label="Scan csv "; 37795 [labelType="html" label="FileScanRDD [37795] parquet at PersistJob.java:35"]; 37796 [labelType="html" label="MapPartitionsRDD [37796] parquet at PersistJob.java:35"]; } subgraph cluster88712 { label="WholeStageCodegen (11)"; 37797 [labelType="html" label="MapPartitionsRDD [37797] parquet at PersistJob.java:35"]; } subgraph cluster88711 { label="ObjectHashAggregate"; 37798 [labelType="html" label="MapPartitionsRDD [37798] parquet at PersistJob.java:35"]; } subgraph cluster88710 { label="Exchange"; 37799 [labelType="html" label="MapPartitionsRDD [37799] parquet at PersistJob.java:35"]; } } 37795->37796; 37796->37797; 37797->37798; 37798->37799; }

digraph G { subgraph clusterstage_13693 { label="Stage 13693 (skipped)"; subgraph cluster88918 { label="Scan parquet "; 37924 [labelType="html" label="FileScanRDD [37924] parquet at PersistJob.java:35"]; 37925 [labelType="html" label="MapPartitionsRDD [37925] parquet at PersistJob.java:35"]; } subgraph cluster88913 { label="WholeStageCodegen (43)"; 37926 [labelType="html" label="MapPartitionsRDD [37926] parquet at PersistJob.java:35"]; } subgraph cluster88921 { label="Exchange"; 37927 [labelType="html" label="ShuffledRowRDD [37927] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88919 { label="ObjectHashAggregate"; 37928 [labelType="html" label="MapPartitionsRDD [37928] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88912 { label="CartesianProduct"; 37929 [labelType="html" label="UnsafeCartesianRDD [37929] [Unordered] parquet at PersistJob.java:35"]; 37930 [labelType="html" label="MapPartitionsRDD [37930] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88926 { label="Scan csv "; 37931 [labelType="html" label="FileScanRDD [37931] parquet at PersistJob.java:35"]; 37932 [labelType="html" label="MapPartitionsRDD [37932] parquet at PersistJob.java:35"]; } subgraph cluster88922 { label="WholeStageCodegen (44)"; 37933 [labelType="html" label="MapPartitionsRDD [37933] parquet at PersistJob.java:35"]; } subgraph cluster88911 { label="CartesianProduct"; 37934 [labelType="html" label="UnsafeCartesianRDD [37934] [Unordered] parquet at PersistJob.java:35"]; 37935 [labelType="html" label="MapPartitionsRDD [37935] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88907 { label="WholeStageCodegen (45)"; 37936 [labelType="html" label="MapPartitionsRDD [37936] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88906 { label="ObjectHashAggregate"; 37937 [labelType="html" label="MapPartitionsRDD [37937] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88905 { label="Exchange"; 37938 [labelType="html" label="MapPartitionsRDD [37938] [Unordered] parquet at PersistJob.java:35"]; } } 37924->37925; 37925->37926; 37927->37928; 37926->37929; 37928->37929; 37929->37930; 37931->37932; 37932->37933; 37930->37934; 37933->37934; 37934->37935; 37935->37936; 37936->37937; 37937->37938; }

37799,37927

digraph G { subgraph clusterstage_13694 { label="Stage 13694 (skipped)"; subgraph cluster89020 { label="AQEShuffleRead"; 37972 [labelType="html" label="ShuffledRowRDD [37972] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89017 { label="WholeStageCodegen (60)"; 37973 [labelType="html" label="MapPartitionsRDD [37973] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89016 { label="Window"; 37974 [labelType="html" label="MapPartitionsRDD [37974] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89010 { label="WholeStageCodegen (61)"; 37975 [labelType="html" label="MapPartitionsRDD [37975] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89025 { label="Scan csv "; 37976 [labelType="html" label="FileScanRDD [37976] parquet at PersistJob.java:35"]; 37977 [labelType="html" label="MapPartitionsRDD [37977] parquet at PersistJob.java:35"]; } subgraph cluster89021 { label="WholeStageCodegen (62)"; 37978 [labelType="html" label="MapPartitionsRDD [37978] parquet at PersistJob.java:35"]; } subgraph cluster89009 { label="CartesianProduct"; 37979 [labelType="html" label="UnsafeCartesianRDD [37979] [Unordered] parquet at PersistJob.java:35"]; 37980 [labelType="html" label="MapPartitionsRDD [37980] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89008 { label="Exchange"; 37981 [labelType="html" label="MapPartitionsRDD [37981] [Unordered] parquet at PersistJob.java:35"]; } } 37972->37973; 37973->37974; 37974->37975; 37976->37977; 37977->37978; 37975->37979; 37978->37979; 37979->37980; 37980->37981; }

37971,37972

digraph G { subgraph clusterstage_13695 { label="Stage 13695 (skipped)"; subgraph cluster88830 { label="Scan parquet "; 37864 [labelType="html" label="FileScanRDD [37864] parquet at PersistJob.java:35"]; 37865 [labelType="html" label="MapPartitionsRDD [37865] parquet at PersistJob.java:35"]; } subgraph cluster88825 { label="WholeStageCodegen (31)"; 37866 [labelType="html" label="MapPartitionsRDD [37866] parquet at PersistJob.java:35"]; } subgraph cluster88833 { label="Exchange"; 37867 [labelType="html" label="ShuffledRowRDD [37867] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88831 { label="ObjectHashAggregate"; 37868 [labelType="html" label="MapPartitionsRDD [37868] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88824 { label="CartesianProduct"; 37869 [labelType="html" label="UnsafeCartesianRDD [37869] [Unordered] parquet at PersistJob.java:35"]; 37870 [labelType="html" label="MapPartitionsRDD [37870] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88838 { label="Scan csv "; 37871 [labelType="html" label="FileScanRDD [37871] parquet at PersistJob.java:35"]; 37872 [labelType="html" label="MapPartitionsRDD [37872] parquet at PersistJob.java:35"]; } subgraph cluster88834 { label="WholeStageCodegen (32)"; 37873 [labelType="html" label="MapPartitionsRDD [37873] parquet at PersistJob.java:35"]; } subgraph cluster88823 { label="CartesianProduct"; 37874 [labelType="html" label="UnsafeCartesianRDD [37874] [Unordered] parquet at PersistJob.java:35"]; 37875 [labelType="html" label="MapPartitionsRDD [37875] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88819 { label="WholeStageCodegen (33)"; 37876 [labelType="html" label="MapPartitionsRDD [37876] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88818 { label="ObjectHashAggregate"; 37877 [labelType="html" label="MapPartitionsRDD [37877] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88817 { label="Exchange"; 37878 [labelType="html" label="MapPartitionsRDD [37878] [Unordered] parquet at PersistJob.java:35"]; } } 37864->37865; 37865->37866; 37867->37868; 37866->37869; 37868->37869; 37869->37870; 37871->37872; 37872->37873; 37870->37874; 37873->37874; 37874->37875; 37875->37876; 37876->37877; 37877->37878; }

37774,37867

digraph G { subgraph clusterstage_13696 { label="Stage 13696 (skipped)"; subgraph cluster88728 { label="Scan parquet "; 37800 [labelType="html" label="FileScanRDD [37800] parquet at PersistJob.java:35"]; 37801 [labelType="html" label="MapPartitionsRDD [37801] parquet at PersistJob.java:35"]; } subgraph cluster88723 { label="WholeStageCodegen (12)"; 37802 [labelType="html" label="MapPartitionsRDD [37802] parquet at PersistJob.java:35"]; } subgraph cluster88733 { label="Scan csv "; 37803 [labelType="html" label="FileScanRDD [37803] parquet at PersistJob.java:35"]; 37804 [labelType="html" label="MapPartitionsRDD [37804] parquet at PersistJob.java:35"]; } subgraph cluster88729 { label="WholeStageCodegen (13)"; 37805 [labelType="html" label="MapPartitionsRDD [37805] parquet at PersistJob.java:35"]; } subgraph cluster88722 { label="CartesianProduct"; 37806 [labelType="html" label="UnsafeCartesianRDD [37806] parquet at PersistJob.java:35"]; 37807 [labelType="html" label="MapPartitionsRDD [37807] parquet at PersistJob.java:35"]; } subgraph cluster88718 { label="WholeStageCodegen (14)"; 37808 [labelType="html" label="MapPartitionsRDD [37808] parquet at PersistJob.java:35"]; } subgraph cluster88717 { label="ObjectHashAggregate"; 37809 [labelType="html" label="MapPartitionsRDD [37809] parquet at PersistJob.java:35"]; } subgraph cluster88716 { label="Exchange"; 37810 [labelType="html" label="MapPartitionsRDD [37810] parquet at PersistJob.java:35"]; } } 37800->37801; 37801->37802; 37803->37804; 37804->37805; 37802->37806; 37805->37806; 37806->37807; 37807->37808; 37808->37809; 37809->37810; }

digraph G { subgraph clusterstage_13697 { label="Stage 13697 (skipped)"; subgraph cluster88852 { label="Scan parquet "; 37879 [labelType="html" label="FileScanRDD [37879] parquet at PersistJob.java:35"]; 37880 [labelType="html" label="MapPartitionsRDD [37880] parquet at PersistJob.java:35"]; } subgraph cluster88847 { label="WholeStageCodegen (34)"; 37881 [labelType="html" label="MapPartitionsRDD [37881] parquet at PersistJob.java:35"]; } subgraph cluster88855 { label="Exchange"; 37882 [labelType="html" label="ShuffledRowRDD [37882] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88853 { label="ObjectHashAggregate"; 37883 [labelType="html" label="MapPartitionsRDD [37883] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88846 { label="CartesianProduct"; 37884 [labelType="html" label="UnsafeCartesianRDD [37884] [Unordered] parquet at PersistJob.java:35"]; 37885 [labelType="html" label="MapPartitionsRDD [37885] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88860 { label="Scan csv "; 37886 [labelType="html" label="FileScanRDD [37886] parquet at PersistJob.java:35"]; 37887 [labelType="html" label="MapPartitionsRDD [37887] parquet at PersistJob.java:35"]; } subgraph cluster88856 { label="WholeStageCodegen (35)"; 37888 [labelType="html" label="MapPartitionsRDD [37888] parquet at PersistJob.java:35"]; } subgraph cluster88845 { label="CartesianProduct"; 37889 [labelType="html" label="UnsafeCartesianRDD [37889] [Unordered] parquet at PersistJob.java:35"]; 37890 [labelType="html" label="MapPartitionsRDD [37890] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88841 { label="WholeStageCodegen (36)"; 37891 [labelType="html" label="MapPartitionsRDD [37891] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88840 { label="ObjectHashAggregate"; 37892 [labelType="html" label="MapPartitionsRDD [37892] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88839 { label="Exchange"; 37893 [labelType="html" label="MapPartitionsRDD [37893] [Unordered] parquet at PersistJob.java:35"]; } } 37879->37880; 37880->37881; 37882->37883; 37881->37884; 37883->37884; 37884->37885; 37886->37887; 37887->37888; 37885->37889; 37888->37889; 37889->37890; 37890->37891; 37891->37892; 37892->37893; }

37779,37882

digraph G { subgraph clusterstage_13698 { label="Stage 13698 (skipped)"; subgraph cluster88709 { label="Scan csv "; 37790 [labelType="html" label="FileScanRDD [37790] parquet at PersistJob.java:35"]; 37791 [labelType="html" label="MapPartitionsRDD [37791] parquet at PersistJob.java:35"]; } subgraph cluster88706 { label="WholeStageCodegen (10)"; 37792 [labelType="html" label="MapPartitionsRDD [37792] parquet at PersistJob.java:35"]; } subgraph cluster88705 { label="ObjectHashAggregate"; 37793 [labelType="html" label="MapPartitionsRDD [37793] parquet at PersistJob.java:35"]; } subgraph cluster88704 { label="Exchange"; 37794 [labelType="html" label="MapPartitionsRDD [37794] parquet at PersistJob.java:35"]; } } 37790->37791; 37791->37792; 37792->37793; 37793->37794; }

digraph G { subgraph clusterstage_13699 { label="Stage 13699 (skipped)"; subgraph cluster88745 { label="Scan parquet "; 37815 [labelType="html" label="FileScanRDD [37815] parquet at PersistJob.java:35"]; 37816 [labelType="html" label="MapPartitionsRDD [37816] parquet at PersistJob.java:35"]; } subgraph cluster88740 { label="WholeStageCodegen (16)"; 37817 [labelType="html" label="MapPartitionsRDD [37817] parquet at PersistJob.java:35"]; } subgraph cluster88739 { label="Exchange"; 37818 [labelType="html" label="MapPartitionsRDD [37818] parquet at PersistJob.java:35"]; } } 37815->37816; 37816->37817; 37817->37818; }

digraph G { subgraph clusterstage_13700 { label="Stage 13700 (skipped)"; subgraph cluster88786 { label="Scan parquet "; 37834 [labelType="html" label="FileScanRDD [37834] parquet at PersistJob.java:35"]; 37835 [labelType="html" label="MapPartitionsRDD [37835] parquet at PersistJob.java:35"]; } subgraph cluster88781 { label="WholeStageCodegen (25)"; 37836 [labelType="html" label="MapPartitionsRDD [37836] parquet at PersistJob.java:35"]; } subgraph cluster88789 { label="Exchange"; 37837 [labelType="html" label="ShuffledRowRDD [37837] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88787 { label="ObjectHashAggregate"; 37838 [labelType="html" label="MapPartitionsRDD [37838] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88780 { label="CartesianProduct"; 37839 [labelType="html" label="UnsafeCartesianRDD [37839] [Unordered] parquet at PersistJob.java:35"]; 37840 [labelType="html" label="MapPartitionsRDD [37840] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88794 { label="Scan csv "; 37841 [labelType="html" label="FileScanRDD [37841] parquet at PersistJob.java:35"]; 37842 [labelType="html" label="MapPartitionsRDD [37842] parquet at PersistJob.java:35"]; } subgraph cluster88790 { label="WholeStageCodegen (26)"; 37843 [labelType="html" label="MapPartitionsRDD [37843] parquet at PersistJob.java:35"]; } subgraph cluster88779 { label="CartesianProduct"; 37844 [labelType="html" label="UnsafeCartesianRDD [37844] [Unordered] parquet at PersistJob.java:35"]; 37845 [labelType="html" label="MapPartitionsRDD [37845] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88775 { label="WholeStageCodegen (27)"; 37846 [labelType="html" label="MapPartitionsRDD [37846] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88774 { label="ObjectHashAggregate"; 37847 [labelType="html" label="MapPartitionsRDD [37847] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88773 { label="Exchange"; 37848 [labelType="html" label="MapPartitionsRDD [37848] [Unordered] parquet at PersistJob.java:35"]; } } 37834->37835; 37835->37836; 37837->37838; 37836->37839; 37838->37839; 37839->37840; 37841->37842; 37842->37843; 37840->37844; 37843->37844; 37844->37845; 37845->37846; 37846->37847; 37847->37848; }

37753,37837

digraph G { subgraph clusterstage_13701 { label="Stage 13701 (skipped)"; subgraph cluster88808 { label="Scan parquet "; 37849 [labelType="html" label="FileScanRDD [37849] parquet at PersistJob.java:35"]; 37850 [labelType="html" label="MapPartitionsRDD [37850] parquet at PersistJob.java:35"]; } subgraph cluster88803 { label="WholeStageCodegen (28)"; 37851 [labelType="html" label="MapPartitionsRDD [37851] parquet at PersistJob.java:35"]; } subgraph cluster88811 { label="Exchange"; 37852 [labelType="html" label="ShuffledRowRDD [37852] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88809 { label="ObjectHashAggregate"; 37853 [labelType="html" label="MapPartitionsRDD [37853] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88802 { label="CartesianProduct"; 37854 [labelType="html" label="UnsafeCartesianRDD [37854] [Unordered] parquet at PersistJob.java:35"]; 37855 [labelType="html" label="MapPartitionsRDD [37855] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88816 { label="Scan csv "; 37856 [labelType="html" label="FileScanRDD [37856] parquet at PersistJob.java:35"]; 37857 [labelType="html" label="MapPartitionsRDD [37857] parquet at PersistJob.java:35"]; } subgraph cluster88812 { label="WholeStageCodegen (29)"; 37858 [labelType="html" label="MapPartitionsRDD [37858] parquet at PersistJob.java:35"]; } subgraph cluster88801 { label="CartesianProduct"; 37859 [labelType="html" label="UnsafeCartesianRDD [37859] [Unordered] parquet at PersistJob.java:35"]; 37860 [labelType="html" label="MapPartitionsRDD [37860] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88797 { label="WholeStageCodegen (30)"; 37861 [labelType="html" label="MapPartitionsRDD [37861] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88796 { label="ObjectHashAggregate"; 37862 [labelType="html" label="MapPartitionsRDD [37862] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster88795 { label="Exchange"; 37863 [labelType="html" label="MapPartitionsRDD [37863] [Unordered] parquet at PersistJob.java:35"]; } } 37849->37850; 37850->37851; 37852->37853; 37851->37854; 37853->37854; 37854->37855; 37856->37857; 37857->37858; 37855->37859; 37858->37859; 37859->37860; 37860->37861; 37861->37862; 37862->37863; }

37769,37852

digraph G { subgraph clusterstage_13702 { label="Stage 13702"; subgraph cluster89033 { label="Scan csv "; 37982 [labelType="html" label="FileScanRDD [37982] parquet at PersistJob.java:35"]; 37983 [labelType="html" label="MapPartitionsRDD [37983] parquet at PersistJob.java:35"]; } subgraph cluster89028 { label="WholeStageCodegen (63)"; 37984 [labelType="html" label="MapPartitionsRDD [37984] parquet at PersistJob.java:35"]; } subgraph cluster89041 { label="AQEShuffleRead"; 37985 [labelType="html" label="ShuffledRowRDD [37985] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89040 { label="ObjectHashAggregate"; 37986 [labelType="html" label="MapPartitionsRDD [37986] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89034 { label="WholeStageCodegen (64)"; 37987 [labelType="html" label="MapPartitionsRDD [37987] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89049 { label="AQEShuffleRead"; 37988 [labelType="html" label="ShuffledRowRDD [37988] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89048 { label="ObjectHashAggregate"; 37989 [labelType="html" label="MapPartitionsRDD [37989] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89042 { label="WholeStageCodegen (65)"; 37990 [labelType="html" label="MapPartitionsRDD [37990] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89057 { label="AQEShuffleRead"; 37991 [labelType="html" label="ShuffledRowRDD [37991] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89056 { label="ObjectHashAggregate"; 37992 [labelType="html" label="MapPartitionsRDD [37992] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89050 { label="WholeStageCodegen (66)"; 37993 [labelType="html" label="MapPartitionsRDD [37993] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89065 { label="AQEShuffleRead"; 37994 [labelType="html" label="ShuffledRowRDD [37994] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89064 { label="ObjectHashAggregate"; 37995 [labelType="html" label="MapPartitionsRDD [37995] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89058 { label="WholeStageCodegen (67)"; 37996 [labelType="html" label="MapPartitionsRDD [37996] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89078 { label="Scan parquet "; 37997 [labelType="html" label="FileScanRDD [37997] parquet at PersistJob.java:35"]; 37998 [labelType="html" label="MapPartitionsRDD [37998] parquet at PersistJob.java:35"]; } subgraph cluster89073 { label="WholeStageCodegen (68)"; 37999 [labelType="html" label="MapPartitionsRDD [37999] parquet at PersistJob.java:35"]; } subgraph cluster89081 { label="Exchange"; 38000 [labelType="html" label="ShuffledRowRDD [38000] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89079 { label="ObjectHashAggregate"; 38001 [labelType="html" label="MapPartitionsRDD [38001] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89072 { label="CartesianProduct"; 38002 [labelType="html" label="UnsafeCartesianRDD [38002] [Unordered] parquet at PersistJob.java:35"]; 38003 [labelType="html" label="MapPartitionsRDD [38003] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89086 { label="Scan csv "; 38004 [labelType="html" label="FileScanRDD [38004] parquet at PersistJob.java:35"]; 38005 [labelType="html" label="MapPartitionsRDD [38005] parquet at PersistJob.java:35"]; } subgraph cluster89082 { label="WholeStageCodegen (69)"; 38006 [labelType="html" label="MapPartitionsRDD [38006] parquet at PersistJob.java:35"]; } subgraph cluster89071 { label="CartesianProduct"; 38007 [labelType="html" label="UnsafeCartesianRDD [38007] [Unordered] parquet at PersistJob.java:35"]; 38008 [labelType="html" label="MapPartitionsRDD [38008] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89066 { label="WholeStageCodegen (70)"; 38009 [labelType="html" label="MapPartitionsRDD [38009] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89094 { label="AQEShuffleRead"; 38010 [labelType="html" label="ShuffledRowRDD [38010] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89093 { label="ObjectHashAggregate"; 38011 [labelType="html" label="MapPartitionsRDD [38011] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89087 { label="WholeStageCodegen (71)"; 38012 [labelType="html" label="MapPartitionsRDD [38012] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89102 { label="AQEShuffleRead"; 38013 [labelType="html" label="ShuffledRowRDD [38013] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89101 { label="ObjectHashAggregate"; 38014 [labelType="html" label="MapPartitionsRDD [38014] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89095 { label="WholeStageCodegen (72)"; 38015 [labelType="html" label="MapPartitionsRDD [38015] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89114 { label="AQEShuffleRead"; 38016 [labelType="html" label="ShuffledRowRDD [38016] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89111 { label="WholeStageCodegen (73)"; 38017 [labelType="html" label="MapPartitionsRDD [38017] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89119 { label="AQEShuffleRead"; 38018 [labelType="html" label="ShuffledRowRDD [38018] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89116 { label="WholeStageCodegen (74)"; 38019 [labelType="html" label="MapPartitionsRDD [38019] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89103 { label="WholeStageCodegen (75)"; 38020 [labelType="html" label="ZippedPartitionsRDD2 [38020] [Unordered] parquet at PersistJob.java:35"]; 38021 [labelType="html" label="MapPartitionsRDD [38021] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89027 { label="Union"; 38022 [labelType="html" label="UnionRDD [38022] [Unordered] parquet at PersistJob.java:35"]; } subgraph cluster89026 { label="Exchange"; 38023 [labelType="html" label="MapPartitionsRDD [38023] [Unordered] parquet at PersistJob.java:35"]; } } 37982->37983; 37983->37984; 37985->37986; 37986->37987; 37988->37989; 37989->37990; 37991->37992; 37992->37993; 37994->37995; 37995->37996; 37997->37998; 37998->37999; 38000->38001; 37999->38002; 38001->38002; 38002->38003; 38004->38005; 38005->38006; 38003->38007; 38006->38007; 38007->38008; 38008->38009; 38010->38011; 38011->38012; 38013->38014; 38014->38015; 38016->38017; 38018->38019; 38017->38020; 38019->38020; 38020->38021; 37984->38022; 37987->38022; 37990->38022; 37993->38022; 37996->38022; 38009->38022; 38012->38022; 38015->38022; 38021->38022; 38022->38023; }

37848,37985

37863,37988

37878,37991

37893,37994

37794,38000

37938,38010

37810,38013

37981,38016

37818,38018

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
13702	default	PersistFrame parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/10/20 09:17:43	5 s	19/19	13.5 MiB		3.1 MiB	1466.1 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

13702

default

PersistFrame parquet at PersistJob.java:35 +details

org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802)
com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
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/10/20 09:17:43

5 s

19/19

13.5 MiB

3.1 MiB

1466.1 KiB

Page:

Skipped Stages (18)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
13701	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/10
13700	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/10
13699	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/5
13698	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/1
13697	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/10
13696	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/10
13695	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/10
13694	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/1
13693	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/10
13692	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/1
13691	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/1
13690	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/5
13689	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/10
13688	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/1
13687	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/1
13686	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/1
13685	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/1
13684	default	parquet at PersistJob.java:35 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77) com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) 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/1

Page: