EVAL1_SPC1 - Details for Job 796

Status: SUCCEEDED
Submitted: 2026/02/20 12:44:54
Duration: 12 ms
Associated SQL Query: 653
Job Group: d74d3d2d-5ec3-40a8-9eb8-93f7ab3aedfd
Completed Stages: 1
Skipped Stages: 1

Enable zooming

digraph G { subgraph clusterstage_1012 { label="Stage 1012 (skipped)"; subgraph cluster6949 { label="Scan parquet "; 2655 [labelType="html" label="FileScanRDD [2655] count at ColumnStatJob.java:47"]; 2656 [labelType="html" label="MapPartitionsRDD [2656] count at ColumnStatJob.java:47"]; } subgraph cluster6946 { label="WholeStageCodegen (1)"; 2657 [labelType="html" label="MapPartitionsRDD [2657] count at ColumnStatJob.java:47"]; } subgraph cluster6945 { label="Filter"; 2658 [labelType="html" label="MapPartitionsRDD [2658] count at ColumnStatJob.java:47"]; } subgraph cluster6944 { label="Project"; 2659 [labelType="html" label="MapPartitionsRDD [2659] count at ColumnStatJob.java:47"]; } subgraph cluster6941 { label="WholeStageCodegen (2)"; 2660 [labelType="html" label="MapPartitionsRDD [2660] count at ColumnStatJob.java:47"]; } subgraph cluster6940 { label="Filter"; 2661 [labelType="html" label="MapPartitionsRDD [2661] count at ColumnStatJob.java:47"]; } subgraph cluster6936 { label="WholeStageCodegen (3)"; 2662 [labelType="html" label="MapPartitionsRDD [2662] count at ColumnStatJob.java:47"]; } subgraph cluster6935 { label="Exchange"; 2663 [labelType="html" label="MapPartitionsRDD [2663] count at ColumnStatJob.java:47"]; } } 2655->2656; 2656->2657; 2657->2658; 2658->2659; 2659->2660; 2660->2661; 2661->2662; 2662->2663; }

digraph G { subgraph clusterstage_1013 { label="Stage 1013"; subgraph cluster6971 { label="Exchange"; 2674 [labelType="html" label="ShuffledRowRDD [2674] [Unordered] count at ColumnStatJob.java:47"]; } subgraph cluster6967 { label="WholeStageCodegen (4)"; 2675 [labelType="html" label="MapPartitionsRDD [2675] [Unordered] count at ColumnStatJob.java:47"]; } subgraph cluster6972 { label="mapPartitionsInternal"; 2676 [labelType="html" label="MapPartitionsRDD [2676] [Unordered] count at ColumnStatJob.java:47"]; } } 2674->2675; 2675->2676; }

2663,2674

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1013	default	DataFrameCommonJob_dataExecSummary count at ColumnStatJob.java:47 +details org.apache.spark.sql.Dataset.count(Dataset.scala:3615) com.adb.hdh.spark.job.impl.ColumnStatJob.stats(ColumnStatJob.java:47) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:35) 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 12:44:54	6 ms	1/1			171.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1013

default

DataFrameCommonJob_dataExecSummary count at ColumnStatJob.java:47 +details

org.apache.spark.sql.Dataset.count(Dataset.scala:3615)
com.adb.hdh.spark.job.impl.ColumnStatJob.stats(ColumnStatJob.java:47)
com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:35)
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 12:44:54

6 ms

1/1

171.0 B

Page:

Skipped Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1012	default	count at ColumnStatJob.java:47 +details org.apache.spark.sql.Dataset.count(Dataset.scala:3615) com.adb.hdh.spark.job.impl.ColumnStatJob.stats(ColumnStatJob.java:47) com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:35) 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/3

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1012

default

count at ColumnStatJob.java:47 +details

org.apache.spark.sql.Dataset.count(Dataset.scala:3615)
com.adb.hdh.spark.job.impl.ColumnStatJob.stats(ColumnStatJob.java:47)
com.adb.hdh.spark.job.impl.ExecDataJob.exec(ExecDataJob.java:35)
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/3

Page: