The wrong metric is being sent in MetricsReporter.scala
The current implementation for processingRate-total is assigned the wrong metric:
Look at the first and second registerGauge. The second one mistakenly uses inputRowsPerSecond instead of processedRowsPerSecond.
After adjusting the line and rebuilding from source I tested the change by checking the csv files produced via the metrics properties file. Previously inputRate-total and processingRate-total were identical due to the same metric being used. After the change the processingRate-total file held the right value.
Please check the attached file "Processed Rows Per Second".
After altering the code the correct values are displayed in column B.
They match the data from the INFO StreamExecution displayed during streaming