Skip to content

Commit c0dcd24

Browse files
committed
no need to reset metrics
1 parent ce0e126 commit c0dcd24

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

sql/core/src/main/scala/org/apache/spark/sql/DataFrameWriter.scala

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -578,9 +578,6 @@ final class DataFrameWriter[T] private[sql](ds: Dataset[T]) {
578578
private def runCommand(session: SparkSession, name: String)(command: LogicalPlan): Unit = {
579579
val qe = session.sessionState.executePlan(command)
580580
try {
581-
qe.executedPlan.foreach { plan =>
582-
plan.resetMetrics()
583-
}
584581
val start = System.nanoTime()
585582
// call `QueryExecution.toRDD` to trigger the execution of commands.
586583
qe.toRdd

0 commit comments

Comments
 (0)