EVAL1_SPC1 - Details for Job 880

Status: SUCCEEDED
Submitted: 2026/02/20 13:33:51
Duration: 0.1 s
Associated SQL Query: 713
Job Group: c15d3fa6-6f28-4121-bfc0-f67d49b67b6c
Completed Stages: 1
Skipped Stages: 2

Enable zooming

digraph G { subgraph clusterstage_1125 { label="Stage 1125 (skipped)"; subgraph cluster7713 { label="Scan parquet "; 2966 [labelType="html" label="FileScanRDD [2966] takeAsList at DataFrameCommonJob.java:145"]; 2967 [labelType="html" label="MapPartitionsRDD [2967] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7709 { label="WholeStageCodegen (1)"; 2968 [labelType="html" label="MapPartitionsRDD [2968] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7708 { label="Exchange"; 2969 [labelType="html" label="MapPartitionsRDD [2969] takeAsList at DataFrameCommonJob.java:145"]; } } 2966->2967; 2967->2968; 2968->2969; }

digraph G { subgraph clusterstage_1126 { label="Stage 1126 (skipped)"; subgraph cluster7720 { label="Scan parquet "; 2970 [labelType="html" label="FileScanRDD [2970] takeAsList at DataFrameCommonJob.java:145"]; 2971 [labelType="html" label="MapPartitionsRDD [2971] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7715 { label="WholeStageCodegen (2)"; 2972 [labelType="html" label="MapPartitionsRDD [2972] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7714 { label="Exchange"; 2973 [labelType="html" label="MapPartitionsRDD [2973] takeAsList at DataFrameCommonJob.java:145"]; } } 2970->2971; 2971->2972; 2972->2973; }

digraph G { subgraph clusterstage_1127 { label="Stage 1127"; subgraph cluster7757 { label="AQEShuffleRead"; 2977 [labelType="html" label="ShuffledRowRDD [2977] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7754 { label="WholeStageCodegen (3)"; 2978 [labelType="html" label="MapPartitionsRDD [2978] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7753 { label="Window"; 2979 [labelType="html" label="MapPartitionsRDD [2979] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7750 { label="WholeStageCodegen (4)"; 2980 [labelType="html" label="MapPartitionsRDD [2980] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7762 { label="AQEShuffleRead"; 2981 [labelType="html" label="ShuffledRowRDD [2981] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7759 { label="WholeStageCodegen (5)"; 2982 [labelType="html" label="MapPartitionsRDD [2982] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7746 { label="WholeStageCodegen (6)"; 2983 [labelType="html" label="ZippedPartitionsRDD2 [2983] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; 2984 [labelType="html" label="MapPartitionsRDD [2984] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } subgraph cluster7763 { label="mapPartitionsInternal"; 2985 [labelType="html" label="MapPartitionsRDD [2985] [Unordered] takeAsList at DataFrameCommonJob.java:145"]; } } 2977->2978; 2978->2979; 2979->2980; 2981->2982; 2980->2983; 2982->2983; 2983->2984; 2984->2985; }

2969,2977

2973,2981

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1127	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/02/20 13:33:51	0.1 s	1/1			145.5 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1127

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/02/20 13:33:51

0.1 s

1/1

145.5 KiB

Page:

Skipped Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1126	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
1125	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

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1126

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

0/1

1125

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

0/1

Page: