Skip to content

[SPARK-22052] Incorrect Metric assigned in MetricsReporter.scala - #19268

Closed
Taaffy wants to merge 1 commit into
apache:masterfrom
Taaffy:patch-1
Closed

[SPARK-22052] Incorrect Metric assigned in MetricsReporter.scala#19268
Taaffy wants to merge 1 commit into
apache:masterfrom
Taaffy:patch-1

Conversation

@Taaffy

Copy link
Copy Markdown
Contributor

Current implementation for processingRate-total uses wrong metric:
mistakenly uses inputRowsPerSecond instead of processedRowsPerSecond

What changes were proposed in this pull request?

Adjust processingRate-total from using inputRowsPerSecond to processedRowsPerSecond

How was this patch tested?

Built spark from source with proposed change and tested output with correct parameter. Before change the csv metrics file for inputRate-total and processingRate-total displayed the same values due to the error. After changing MetricsReporter.scala the processingRate-total csv file displayed the correct metric.
processed rows per second

Please review http://spark.apache.org/contributing.html before opening a pull request.

Current implementation for processingRate-total uses wrong metric:
mistakenly uses inputRowsPerSecond instead of processedRowsPerSecond
@srowen

Copy link
Copy Markdown
Member

Please make a JIRA @Taaffy

@Taaffy

Copy link
Copy Markdown
ContributorAuthor

Will do. Delete this pull afterwards?

@srowen

Copy link
Copy Markdown
Member

No way to make the change without a PR, so no leave it.
http://spark.apache.org/contributing.html

@TaaffyTaaffy changed the title Incorrect Metric reported in MetricsReporter.scala[SPARK-22052] Incorrect Metric reported in MetricsReporter.scalaSep 18, 2017
@SparkQA

Copy link
Copy Markdown

Test build #3926 has finished for PR 19268 at commit afe083f.

  • This patch passes all tests.
  • This patch merges cleanly.
  • This patch adds no public classes.

@TaaffyTaaffy changed the title [SPARK-22052] Incorrect Metric reported in MetricsReporter.scala[SPARK-22052] Incorrect Metric assigned in MetricsReporter.scalaSep 18, 2017
asfgit pushed a commit that referenced this pull request Sep 19, 2017
Current implementation for processingRate-total uses wrong metric:
mistakenly uses inputRowsPerSecond instead of processedRowsPerSecond
## What changes were proposed in this pull request?
Adjust processingRate-total from using inputRowsPerSecond to processedRowsPerSecond
## How was this patch tested?
Built spark from source with proposed change and tested output with correct parameter. Before change the csv metrics file for inputRate-total and processingRate-total displayed the same values due to the error. After changing MetricsReporter.scala the processingRate-total csv file displayed the correct metric.
<img width="963" alt="processed rows per second" src="https://user-images.githubusercontent.com/32072374/30554340-82eea12c-9ca4-11e7-8370-8168526ff9a2.png">
Please review http://spark.apache.org/contributing.html before opening a pull request.
Author: Taaffy <32072374+Taaffy@users.noreply.github.com>
Closes#19268 from Taaffy/patch-1.
(cherry picked from commit 1bc17a6)
Signed-off-by: Sean Owen <sowen@cloudera.com>
asfgit pushed a commit that referenced this pull request Sep 19, 2017
Current implementation for processingRate-total uses wrong metric:
mistakenly uses inputRowsPerSecond instead of processedRowsPerSecond
## What changes were proposed in this pull request?
Adjust processingRate-total from using inputRowsPerSecond to processedRowsPerSecond
## How was this patch tested?
Built spark from source with proposed change and tested output with correct parameter. Before change the csv metrics file for inputRate-total and processingRate-total displayed the same values due to the error. After changing MetricsReporter.scala the processingRate-total csv file displayed the correct metric.
<img width="963" alt="processed rows per second" src="https://user-images.githubusercontent.com/32072374/30554340-82eea12c-9ca4-11e7-8370-8168526ff9a2.png">
Please review http://spark.apache.org/contributing.html before opening a pull request.
Author: Taaffy <32072374+Taaffy@users.noreply.github.com>
Closes#19268 from Taaffy/patch-1.
(cherry picked from commit 1bc17a6)
Signed-off-by: Sean Owen <sowen@cloudera.com>
@srowen

Copy link
Copy Markdown
Member

Merged to master/2.2/2.1

MatthewRBruce pushed a commit to Shopify/spark that referenced this pull request Jul 31, 2018
Current implementation for processingRate-total uses wrong metric:
mistakenly uses inputRowsPerSecond instead of processedRowsPerSecond
## What changes were proposed in this pull request?
Adjust processingRate-total from using inputRowsPerSecond to processedRowsPerSecond
## How was this patch tested?
Built spark from source with proposed change and tested output with correct parameter. Before change the csv metrics file for inputRate-total and processingRate-total displayed the same values due to the error. After changing MetricsReporter.scala the processingRate-total csv file displayed the correct metric.
<img width="963" alt="processed rows per second" src="https://user-images.githubusercontent.com/32072374/30554340-82eea12c-9ca4-11e7-8370-8168526ff9a2.png">
Please review http://spark.apache.org/contributing.html before opening a pull request.
Author: Taaffy <32072374+Taaffy@users.noreply.github.com>
Closesapache#19268 from Taaffy/patch-1.
(cherry picked from commit 1bc17a6)
Signed-off-by: Sean Owen <sowen@cloudera.com>
jzhuge pushed a commit to jzhuge/spark that referenced this pull request Aug 20, 2018
Current implementation for processingRate-total uses wrong metric:
mistakenly uses inputRowsPerSecond instead of processedRowsPerSecond
Adjust processingRate-total from using inputRowsPerSecond to processedRowsPerSecond
Built spark from source with proposed change and tested output with correct parameter. Before change the csv metrics file for inputRate-total and processingRate-total displayed the same values due to the error. After changing MetricsReporter.scala the processingRate-total csv file displayed the correct metric.
<img width="963" alt="processed rows per second" src="https://user-images.githubusercontent.com/32072374/30554340-82eea12c-9ca4-11e7-8370-8168526ff9a2.png">
Please review http://spark.apache.org/contributing.html before opening a pull request.
Author: Taaffy <32072374+Taaffy@users.noreply.github.com>
Closesapache#19268 from Taaffy/patch-1.
Sign up for freeto join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants

@Taaffy@srowen@SparkQA