SP1 - Details for Job 4258

Status: SUCCEEDED
Submitted: 2026/06/11 11:09:25
Duration: 0.1 s
Associated SQL Query: 2792
Job Group: ba9a6b51-3fed-40e7-9fa1-8d4b78789064
Completed Stages: 1
Skipped Stages: 15

Enable zooming

digraph G { subgraph clusterstage_9414 { label="Stage 9414 (skipped)"; subgraph cluster56167 { label="Scan parquet "; 23944 [labelType="html" label="FileScanRDD [23944] takeAsList at DataFrameCommonJob.java:145"]; 23945 [labelType="html" label="MapPartitionsRDD [23945] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56161 { label="WholeStageCodegen (2)"; 23946 [labelType="html" label="MapPartitionsRDD [23946] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56160 { label="Exchange"; 23947 [labelType="html" label="MapPartitionsRDD [23947] takeAsList at DataFrameCommonJob.java:145"]; } } 23944->23945; 23945->23946; 23946->23947; }

digraph G { subgraph clusterstage_9415 { label="Stage 9415 (skipped)"; subgraph cluster56173 { label="Scan csv "; 23948 [labelType="html" label="FileScanRDD [23948] takeAsList at DataFrameCommonJob.java:145"]; 23949 [labelType="html" label="MapPartitionsRDD [23949] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56169 { label="WholeStageCodegen (3)"; 23950 [labelType="html" label="MapPartitionsRDD [23950] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56168 { label="Exchange"; 23951 [labelType="html" label="MapPartitionsRDD [23951] takeAsList at DataFrameCommonJob.java:145"]; } } 23948->23949; 23949->23950; 23950->23951; }

digraph G { subgraph clusterstage_9416 { label="Stage 9416 (skipped)"; subgraph cluster56159 { label="Scan csv "; 23940 [labelType="html" label="FileScanRDD [23940] takeAsList at DataFrameCommonJob.java:145"]; 23941 [labelType="html" label="MapPartitionsRDD [23941] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56155 { label="WholeStageCodegen (1)"; 23942 [labelType="html" label="MapPartitionsRDD [23942] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56154 { label="Exchange"; 23943 [labelType="html" label="MapPartitionsRDD [23943] takeAsList at DataFrameCommonJob.java:145"]; } } 23940->23941; 23941->23942; 23942->23943; }

digraph G { subgraph clusterstage_9417 { label="Stage 9417 (skipped)"; subgraph cluster56219 { label="AQEShuffleRead"; 23976 [labelType="html" label="ShuffledRowRDD [23976] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56216 { label="WholeStageCodegen (10)"; 23977 [labelType="html" label="MapPartitionsRDD [23977] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56215 { label="Exchange"; 23978 [labelType="html" label="MapPartitionsRDD [23978] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } } 23976->23977; 23977->23978; }

23947,23976

digraph G { subgraph clusterstage_9418 { label="Stage 9418 (skipped)"; subgraph cluster56179 { label="Scan csv "; 23952 [labelType="html" label="FileScanRDD [23952] takeAsList at DataFrameCommonJob.java:145"]; 23953 [labelType="html" label="MapPartitionsRDD [23953] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56175 { label="WholeStageCodegen (4)"; 23954 [labelType="html" label="MapPartitionsRDD [23954] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56174 { label="Exchange"; 23955 [labelType="html" label="MapPartitionsRDD [23955] takeAsList at DataFrameCommonJob.java:145"]; } } 23952->23953; 23953->23954; 23954->23955; }

digraph G { subgraph clusterstage_9419 { label="Stage 9419 (skipped)"; subgraph cluster56244 { label="AQEShuffleRead"; 23979 [labelType="html" label="ShuffledRowRDD [23979] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56241 { label="WholeStageCodegen (11)"; 23980 [labelType="html" label="MapPartitionsRDD [23980] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56254 { label="AQEShuffleRead"; 23981 [labelType="html" label="ShuffledRowRDD [23981] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56251 { label="WholeStageCodegen (12)"; 23982 [labelType="html" label="MapPartitionsRDD [23982] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56250 { label="Window"; 23983 [labelType="html" label="MapPartitionsRDD [23983] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56246 { label="WholeStageCodegen (13)"; 23984 [labelType="html" label="MapPartitionsRDD [23984] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56235 { label="WholeStageCodegen (14)"; 23985 [labelType="html" label="ZippedPartitionsRDD2 [23985] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; 23986 [labelType="html" label="MapPartitionsRDD [23986] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56234 { label="Window"; 23987 [labelType="html" label="MapPartitionsRDD [23987] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56231 { label="WholeStageCodegen (15)"; 23988 [labelType="html" label="MapPartitionsRDD [23988] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56264 { label="AQEShuffleRead"; 23989 [labelType="html" label="ShuffledRowRDD [23989] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56261 { label="WholeStageCodegen (16)"; 23990 [labelType="html" label="MapPartitionsRDD [23990] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56260 { label="Window"; 23991 [labelType="html" label="MapPartitionsRDD [23991] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56256 { label="WholeStageCodegen (17)"; 23992 [labelType="html" label="MapPartitionsRDD [23992] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56225 { label="WholeStageCodegen (18)"; 23993 [labelType="html" label="ZippedPartitionsRDD2 [23993] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; 23994 [labelType="html" label="MapPartitionsRDD [23994] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56269 { label="Scan parquet "; 23995 [labelType="html" label="FileScanRDD [23995] takeAsList at DataFrameCommonJob.java:145"]; 23996 [labelType="html" label="MapPartitionsRDD [23996] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56265 { label="WholeStageCodegen (19)"; 23997 [labelType="html" label="MapPartitionsRDD [23997] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56224 { label="CartesianProduct"; 23998 [labelType="html" label="UnsafeCartesianRDD [23998] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; 23999 [labelType="html" label="MapPartitionsRDD [23999] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56221 { label="WholeStageCodegen (20)"; 24000 [labelType="html" label="MapPartitionsRDD [24000] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56220 { label="Exchange"; 24001 [labelType="html" label="MapPartitionsRDD [24001] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } } 23979->23980; 23981->23982; 23982->23983; 23983->23984; 23980->23985; 23984->23985; 23985->23986; 23986->23987; 23987->23988; 23989->23990; 23990->23991; 23991->23992; 23988->23993; 23992->23993; 23993->23994; 23995->23996; 23996->23997; 23994->23998; 23997->23998; 23998->23999; 23999->24000; 24000->24001; }

23943,23979

23978,23981

23951,23989

digraph G { subgraph clusterstage_9420 { label="Stage 9420 (skipped)"; subgraph cluster56186 { label="Scan parquet "; 23956 [labelType="html" label="FileScanRDD [23956] takeAsList at DataFrameCommonJob.java:145"]; 23957 [labelType="html" label="MapPartitionsRDD [23957] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56181 { label="WholeStageCodegen (5)"; 23958 [labelType="html" label="MapPartitionsRDD [23958] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56180 { label="Exchange"; 23959 [labelType="html" label="MapPartitionsRDD [23959] takeAsList at DataFrameCommonJob.java:145"]; } } 23956->23957; 23957->23958; 23958->23959; }

digraph G { subgraph clusterstage_9421 { label="Stage 9421 (skipped)"; subgraph cluster56193 { label="Scan parquet "; 23960 [labelType="html" label="FileScanRDD [23960] takeAsList at DataFrameCommonJob.java:145"]; 23961 [labelType="html" label="MapPartitionsRDD [23961] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56188 { label="WholeStageCodegen (6)"; 23962 [labelType="html" label="MapPartitionsRDD [23962] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56187 { label="Exchange"; 23963 [labelType="html" label="MapPartitionsRDD [23963] takeAsList at DataFrameCommonJob.java:145"]; } } 23960->23961; 23961->23962; 23962->23963; }

digraph G { subgraph clusterstage_9422 { label="Stage 9422 (skipped)"; subgraph cluster56200 { label="Scan parquet "; 23964 [labelType="html" label="FileScanRDD [23964] takeAsList at DataFrameCommonJob.java:145"]; 23965 [labelType="html" label="MapPartitionsRDD [23965] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56195 { label="WholeStageCodegen (7)"; 23966 [labelType="html" label="MapPartitionsRDD [23966] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56194 { label="Exchange"; 23967 [labelType="html" label="MapPartitionsRDD [23967] takeAsList at DataFrameCommonJob.java:145"]; } } 23964->23965; 23965->23966; 23966->23967; }

digraph G { subgraph clusterstage_9423 { label="Stage 9423 (skipped)"; subgraph cluster56280 { label="AQEShuffleRead"; 24002 [labelType="html" label="ShuffledRowRDD [24002] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56277 { label="WholeStageCodegen (21)"; 24003 [labelType="html" label="MapPartitionsRDD [24003] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56285 { label="AQEShuffleRead"; 24004 [labelType="html" label="ShuffledRowRDD [24004] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56282 { label="WholeStageCodegen (22)"; 24005 [labelType="html" label="MapPartitionsRDD [24005] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56271 { label="WholeStageCodegen (23)"; 24006 [labelType="html" label="ZippedPartitionsRDD2 [24006] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; 24007 [labelType="html" label="MapPartitionsRDD [24007] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56270 { label="Exchange"; 24008 [labelType="html" label="MapPartitionsRDD [24008] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } } 24002->24003; 24004->24005; 24003->24006; 24005->24006; 24006->24007; 24007->24008; }

24001,24002

23955,24004

digraph G { subgraph clusterstage_9424 { label="Stage 9424 (skipped)"; subgraph cluster56302 { label="AQEShuffleRead"; 24009 [labelType="html" label="ShuffledRowRDD [24009] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56299 { label="WholeStageCodegen (24)"; 24010 [labelType="html" label="MapPartitionsRDD [24010] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56307 { label="AQEShuffleRead"; 24011 [labelType="html" label="ShuffledRowRDD [24011] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56304 { label="WholeStageCodegen (25)"; 24012 [labelType="html" label="MapPartitionsRDD [24012] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56295 { label="WholeStageCodegen (26)"; 24013 [labelType="html" label="ZippedPartitionsRDD2 [24013] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; 24014 [labelType="html" label="MapPartitionsRDD [24014] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56312 { label="AQEShuffleRead"; 24015 [labelType="html" label="ShuffledRowRDD [24015] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56309 { label="WholeStageCodegen (27)"; 24016 [labelType="html" label="MapPartitionsRDD [24016] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56291 { label="WholeStageCodegen (28)"; 24017 [labelType="html" label="ZippedPartitionsRDD2 [24017] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; 24018 [labelType="html" label="MapPartitionsRDD [24018] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56317 { label="AQEShuffleRead"; 24019 [labelType="html" label="ShuffledRowRDD [24019] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56314 { label="WholeStageCodegen (29)"; 24020 [labelType="html" label="MapPartitionsRDD [24020] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56287 { label="WholeStageCodegen (30)"; 24021 [labelType="html" label="ZippedPartitionsRDD2 [24021] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; 24022 [labelType="html" label="MapPartitionsRDD [24022] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56286 { label="Exchange"; 24023 [labelType="html" label="MapPartitionsRDD [24023] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } } 24009->24010; 24011->24012; 24010->24013; 24012->24013; 24013->24014; 24015->24016; 24014->24017; 24016->24017; 24017->24018; 24019->24020; 24018->24021; 24020->24021; 24021->24022; 24022->24023; }

24008,24009

23959,24011

23963,24015

23967,24019

digraph G { subgraph clusterstage_9425 { label="Stage 9425 (skipped)"; subgraph cluster56214 { label="Scan parquet "; 23972 [labelType="html" label="FileScanRDD [23972] takeAsList at DataFrameCommonJob.java:145"]; 23973 [labelType="html" label="MapPartitionsRDD [23973] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56209 { label="WholeStageCodegen (9)"; 23974 [labelType="html" label="MapPartitionsRDD [23974] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56208 { label="Exchange"; 23975 [labelType="html" label="MapPartitionsRDD [23975] takeAsList at DataFrameCommonJob.java:145"]; } } 23972->23973; 23973->23974; 23974->23975; }

digraph G { subgraph clusterstage_9426 { label="Stage 9426 (skipped)"; subgraph cluster56207 { label="Scan parquet "; 23968 [labelType="html" label="FileScanRDD [23968] takeAsList at DataFrameCommonJob.java:145"]; 23969 [labelType="html" label="MapPartitionsRDD [23969] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56202 { label="WholeStageCodegen (8)"; 23970 [labelType="html" label="MapPartitionsRDD [23970] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56201 { label="Exchange"; 23971 [labelType="html" label="MapPartitionsRDD [23971] takeAsList at DataFrameCommonJob.java:145"]; } } 23968->23969; 23969->23970; 23970->23971; }

digraph G { subgraph clusterstage_9427 { label="Stage 9427 (skipped)"; subgraph cluster56333 { label="AQEShuffleRead"; 24024 [labelType="html" label="ShuffledRowRDD [24024] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56330 { label="WholeStageCodegen (31)"; 24025 [labelType="html" label="MapPartitionsRDD [24025] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56338 { label="AQEShuffleRead"; 24026 [labelType="html" label="ShuffledRowRDD [24026] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56335 { label="WholeStageCodegen (32)"; 24027 [labelType="html" label="MapPartitionsRDD [24027] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56324 { label="WholeStageCodegen (33)"; 24028 [labelType="html" label="ZippedPartitionsRDD2 [24028] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; 24029 [labelType="html" label="MapPartitionsRDD [24029] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56343 { label="AQEShuffleRead"; 24030 [labelType="html" label="ShuffledRowRDD [24030] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56340 { label="WholeStageCodegen (34)"; 24031 [labelType="html" label="MapPartitionsRDD [24031] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56319 { label="WholeStageCodegen (35)"; 24032 [labelType="html" label="ZippedPartitionsRDD2 [24032] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; 24033 [labelType="html" label="MapPartitionsRDD [24033] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56318 { label="Exchange"; 24034 [labelType="html" label="MapPartitionsRDD [24034] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } } 24024->24025; 24026->24027; 24025->24028; 24027->24028; 24028->24029; 24030->24031; 24029->24032; 24031->24032; 24032->24033; 24033->24034; }

24023,24024

23971,24026

23975,24030

digraph G { subgraph clusterstage_9428 { label="Stage 9428 (skipped)"; subgraph cluster56362 { label="AQEShuffleRead"; 24035 [labelType="html" label="ShuffledRowRDD [24035] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56359 { label="WholeStageCodegen (36)"; 24036 [labelType="html" label="MapPartitionsRDD [24036] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56358 { label="Window"; 24037 [labelType="html" label="MapPartitionsRDD [24037] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56353 { label="WholeStageCodegen (37)"; 24038 [labelType="html" label="MapPartitionsRDD [24038] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56352 { label="Window"; 24039 [labelType="html" label="MapPartitionsRDD [24039] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56349 { label="WholeStageCodegen (38)"; 24040 [labelType="html" label="MapPartitionsRDD [24040] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56348 { label="Window"; 24041 [labelType="html" label="MapPartitionsRDD [24041] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56345 { label="WholeStageCodegen (39)"; 24042 [labelType="html" label="MapPartitionsRDD [24042] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56344 { label="Exchange"; 24043 [labelType="html" label="MapPartitionsRDD [24043] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } } 24035->24036; 24036->24037; 24037->24038; 24038->24039; 24039->24040; 24040->24041; 24041->24042; 24042->24043; }

24034,24035

digraph G { subgraph clusterstage_9429 { label="Stage 9429"; subgraph cluster56370 { label="AQEShuffleRead"; 24044 [labelType="html" label="ShuffledRowRDD [24044] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56367 { label="WholeStageCodegen (40)"; 24045 [labelType="html" label="MapPartitionsRDD [24045] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56366 { label="Window"; 24046 [labelType="html" label="MapPartitionsRDD [24046] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56363 { label="WholeStageCodegen (41)"; 24047 [labelType="html" label="MapPartitionsRDD [24047] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster56371 { label="mapPartitionsInternal"; 24048 [labelType="html" label="MapPartitionsRDD [24048] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } } 24044->24045; 24045->24046; 24046->24047; 24047->24048; }

24043,24044

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
9429	default	DataFrameCommonJob_dataExec takeAsList at DataFrameCommonJob.java:145 +details org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562) com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142) 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/06/11 11:09:25	0.1 s	1/1			1439.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

9429

default

DataFrameCommonJob_dataExec takeAsList at DataFrameCommonJob.java:145 +details

org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145)
com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142)
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/06/11 11:09:25

0.1 s

1/1

1439.0 B

Page:

Skipped Stages (15)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
9428	default	takeAsList at DataFrameCommonJob.java:145 +details org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562) com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142) 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
9427	default	takeAsList at DataFrameCommonJob.java:145 +details org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562) com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142) 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
9426	default	takeAsList at DataFrameCommonJob.java:145 +details org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562) com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142) 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
9425	default	takeAsList at DataFrameCommonJob.java:145 +details org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562) com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142) 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
9424	default	takeAsList at DataFrameCommonJob.java:145 +details org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562) com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142) 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
9423	default	takeAsList at DataFrameCommonJob.java:145 +details org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562) com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142) 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
9422	default	takeAsList at DataFrameCommonJob.java:145 +details org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562) com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142) 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
9421	default	takeAsList at DataFrameCommonJob.java:145 +details org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562) com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142) 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
9420	default	takeAsList at DataFrameCommonJob.java:145 +details org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562) com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142) 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
9419	default	takeAsList at DataFrameCommonJob.java:145 +details org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562) com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142) 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
9418	default	takeAsList at DataFrameCommonJob.java:145 +details org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562) com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142) 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
9417	default	takeAsList at DataFrameCommonJob.java:145 +details org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562) com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142) 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
9416	default	takeAsList at DataFrameCommonJob.java:145 +details org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562) com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142) 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
9415	default	takeAsList at DataFrameCommonJob.java:145 +details org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562) com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142) 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/2
9414	default	takeAsList at DataFrameCommonJob.java:145 +details org.apache.spark.sql.Dataset.takeAsList(Dataset.scala:3562) com.adb.hdh.spark.job.impl.DataFrameCommonJob.take(DataFrameCommonJob.java:145) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:39) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:142) 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

Page: