diff options
| author | Rahul Singhal <rahul.singhal@guavus.com> | 2014-08-01 00:33:15 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@databricks.com> | 2014-08-01 00:33:15 -0700 |
| commit | f1957e11652a537efd40771f843591a4c9341014 (patch) | |
| tree | bb1133106a3c268b73997bd32c609bd3f0891a47 /extras | |
| parent | 72e33699732496fa71e8c8b0de2203b908423fb2 (diff) | |
| download | spark-f1957e11652a537efd40771f843591a4c9341014.tar.gz spark-f1957e11652a537efd40771f843591a4c9341014.tar.bz2 spark-f1957e11652a537efd40771f843591a4c9341014.zip | |
SPARK-2134: Report metrics before application finishes
Author: Rahul Singhal <rahul.singhal@guavus.com>
Closes #1076 from rahulsinghaliitd/SPARK-2134 and squashes the following commits:
15f18b6 [Rahul Singhal] SPARK-2134: Report metrics before application finishes
Diffstat (limited to 'extras')
| -rw-r--r-- | extras/spark-ganglia-lgpl/src/main/scala/org/apache/spark/metrics/sink/GangliaSink.scala | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/extras/spark-ganglia-lgpl/src/main/scala/org/apache/spark/metrics/sink/GangliaSink.scala b/extras/spark-ganglia-lgpl/src/main/scala/org/apache/spark/metrics/sink/GangliaSink.scala index d03d7774e8..3b1880e143 100644 --- a/extras/spark-ganglia-lgpl/src/main/scala/org/apache/spark/metrics/sink/GangliaSink.scala +++ b/extras/spark-ganglia-lgpl/src/main/scala/org/apache/spark/metrics/sink/GangliaSink.scala @@ -82,5 +82,9 @@ class GangliaSink(val property: Properties, val registry: MetricRegistry, override def stop() { reporter.stop() } + + override def report() { + reporter.report() + } } |