EVAL1_SPC1 - Details for Job 385

Status: SUCCEEDED
Submitted: 2026/06/10 14:34:35
Duration: 3 s
Associated SQL Query: 204
Job Group: 7f0311e8-f6a9-41ef-9c38-cfc3d8849c09
Completed Stages: 1

Enable zooming

digraph G { subgraph clusterstage_738 { label="Stage 738"; 3540 [labelType="html" label="JDBCRDD [3540] toJavaRDD at AbsExportExecutor.java:55"]; 3547 [labelType="html" label="SQLExecutionRDD [3547] toJavaRDD at AbsExportExecutor.java:55"]; subgraph cluster9024 { label="Scan csv "; 3541 [labelType="html" label="FileScanRDD [3541] toJavaRDD at AbsExportExecutor.java:55"]; 3542 [labelType="html" label="MapPartitionsRDD [3542] toJavaRDD at AbsExportExecutor.java:55"]; } subgraph cluster9019 { label="WholeStageCodegen (1)"; 3543 [labelType="html" label="MapPartitionsRDD [3543] toJavaRDD at AbsExportExecutor.java:55"]; } subgraph cluster9025 { label="WholeStageCodegen (2)"; 3544 [labelType="html" label="MapPartitionsRDD [3544] toJavaRDD at AbsExportExecutor.java:55"]; } subgraph cluster9018 { label="Union"; 3545 [labelType="html" label="UnionRDD [3545] toJavaRDD at AbsExportExecutor.java:55"]; } subgraph cluster9017 { label="DeserializeToObject"; 3546 [labelType="html" label="MapPartitionsRDD [3546] toJavaRDD at AbsExportExecutor.java:55"]; } subgraph cluster9030 { label="mapPartitions"; 3548 [labelType="html" label="MapPartitionsRDD [3548] toJavaRDD at AbsExportExecutor.java:55"]; } subgraph cluster9031 { label="map"; 3549 [labelType="html" label="MapPartitionsRDD [3549] createDataFrame at AbsExportExecutor.java:55"]; } subgraph cluster9038 { label="WholeStageCodegen (1)"; 3554 [labelType="html" label="MapPartitionsRDD [3554] parquet at DataFrameParquetWriter.java:12"]; } subgraph cluster9037 { label="Coalesce"; 3555 [labelType="html" label="CoalescedRDD [3555] parquet at DataFrameParquetWriter.java:12"]; } subgraph cluster9036 { label="WriteFiles"; 3556 [labelType="html" label="MapPartitionsRDD [3556] parquet at DataFrameParquetWriter.java:12"]; } } 3541->3542; 3542->3543; 3540->3544; 3543->3545; 3544->3545; 3545->3546; 3546->3547; 3547->3548; 3548->3549; 3549->3554; 3554->3555; 3555->3556; }

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
738	default	DataFrameExportJob_exec_file parquet at DataFrameParquetWriter.java:12 +details org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802) com.adb.hdh.spark.job.impl.exportwriter.DataFrameParquetWriter.write(DataFrameParquetWriter.java:12) com.adb.hdh.spark.job.impl.exportwriter.AbsExportToFileWriter.writeFiles(AbsExportToFileWriter.java:79) com.adb.hdh.spark.job.impl.exportwriter.AbsExportToFileWriter.write(AbsExportToFileWriter.java:58) com.adb.hdh.spark.job.impl.exportexecutor.ExportToFileExecutorImpl.performExport(ExportToFileExecutorImpl.java:69) com.adb.hdh.spark.job.impl.exportexecutor.AbsExportExecutor.writeDataFrame(AbsExportExecutor.java:58) com.adb.hdh.spark.job.impl.exportexecutor.ExportToFileExecutorImpl.execute(ExportToFileExecutorImpl.java:38) com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:160) 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/10 14:34:35	3 s	1/1	514.2 KiB	91.9 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

738

default

DataFrameExportJob_exec_file parquet at DataFrameParquetWriter.java:12 +details

org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802)
com.adb.hdh.spark.job.impl.exportwriter.DataFrameParquetWriter.write(DataFrameParquetWriter.java:12)
com.adb.hdh.spark.job.impl.exportwriter.AbsExportToFileWriter.writeFiles(AbsExportToFileWriter.java:79)
com.adb.hdh.spark.job.impl.exportwriter.AbsExportToFileWriter.write(AbsExportToFileWriter.java:58)
com.adb.hdh.spark.job.impl.exportexecutor.ExportToFileExecutorImpl.performExport(ExportToFileExecutorImpl.java:69)
com.adb.hdh.spark.job.impl.exportexecutor.AbsExportExecutor.writeDataFrame(AbsExportExecutor.java:58)
com.adb.hdh.spark.job.impl.exportexecutor.ExportToFileExecutorImpl.execute(ExportToFileExecutorImpl.java:38)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:160)
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/10 14:34:35

3 s

1/1

514.2 KiB

91.9 KiB

Page: