Skip to content

Commit 5c2c4dc

Browse files
alahvanhovell
authored andcommitted
[SPARK-19447] Remove remaining references to generated rows metric
## What changes were proposed in this pull request? b486ffc left behind references to "number of generated rows" metrics, that should have been removed. ## How was this patch tested? Existing unit tests. Author: Ala Luszczak <[email protected]> Closes #17939 from ala/SPARK-19447-fix.
1 parent fcb88f9 commit 5c2c4dc

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/basicPhysicalOperators.scala

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -340,8 +340,7 @@ case class RangeExec(range: org.apache.spark.sql.catalyst.plans.logical.Range)
340340
override val output: Seq[Attribute] = range.output
341341

342342
override lazy val metrics = Map(
343-
"numOutputRows" -> SQLMetrics.createMetric(sparkContext, "number of output rows"),
344-
"numGeneratedRows" -> SQLMetrics.createMetric(sparkContext, "number of generated rows"))
343+
"numOutputRows" -> SQLMetrics.createMetric(sparkContext, "number of output rows"))
345344

346345
override lazy val canonicalized: SparkPlan = {
347346
RangeExec(range.canonicalized.asInstanceOf[org.apache.spark.sql.catalyst.plans.logical.Range])
@@ -354,7 +353,6 @@ case class RangeExec(range: org.apache.spark.sql.catalyst.plans.logical.Range)
354353

355354
protected override def doProduce(ctx: CodegenContext): String = {
356355
val numOutput = metricTerm(ctx, "numOutputRows")
357-
val numGenerated = metricTerm(ctx, "numGeneratedRows")
358356

359357
val initTerm = ctx.freshName("initRange")
360358
ctx.addMutableState("boolean", initTerm, s"$initTerm = false;")

0 commit comments

Comments
 (0)