Hello Eric Thank you so much. It worked. The topology no longer crashes. Maybe you can answer my other question. Where does the csv file get created? What parameter in storm.yaml controls the location of the csv file. Is there a configuration in the worker.xml and/or cluster.xml file?
Thank you again. Carmen On Tue, Aug 21, 2018 at 4:27 PM Erik Weathers <[email protected]> wrote: > Looks like a typo in the docs to me: > > ➜ storm git:(master) ✗ git checkout v1.2.2 > HEAD is now at d2d6f4034... [maven-release-plugin] prepare release v1.2.2 > ➜ storm git:(d2d6f4034) ✗ git grep CsvReporter > docs/metrics_v2.md: * CSV Reporter > (`org.apache.storm.metrics2.reporters.CsvReporter`): > storm-core/src/jvm/org/apache/storm/daemon/metrics/reporters/CsvPreparableReporter.java:import > com.codahale.metrics.CsvReporter; > storm-core/src/jvm/org/apache/storm/daemon/metrics/reporters/CsvPreparableReporter.java:public > class CsvPreparableReporter implements PreparableReporter<CsvReporter> { > storm-core/src/jvm/org/apache/storm/daemon/metrics/reporters/CsvPreparableReporter.java: > CsvReporter reporter = null; > storm-core/src/jvm/org/apache/storm/daemon/metrics/reporters/CsvPreparableReporter.java: > CsvReporter.Builder builder = CsvReporter.forRegistry(metricsRegistry); > storm-core/src/jvm/org/apache/storm/metrics2/reporters/CsvStormReporter.java:import > com.codahale.metrics.CsvReporter; > storm-core/src/jvm/org/apache/storm/metrics2/reporters/CsvStormReporter.java: > CsvReporter.Builder builder = CsvReporter.forRegistry(metricsRegistry); > > > I'd try: > org.apache.storm.metrics2.reporters.CsvStormReporter > > instead of: > org.apache.storm.metrics2.reporters.CsvReporter > > - Erik > > > On Tue, Aug 21, 2018 at 2:36 PM Carmen M. <[email protected]> wrote: > >> All >> >> I’m trying to use the CsvReporter. When I start the topology, the worker >> crashes. >> >> storm.yaml configuration: >> >> storm.log.dir: "/apps/logs" >> storm.metrics.reporters: >> >> - class: "org.apache.storm.metrics2.reporters.CsvReporter" >> daemons: >> - "supervisor" >> - "nimbus" >> - "worker" >> report.period: 10 >> report.period.units: “SECONDS" >> >> Also, where is the csv file created? >> >> Thank you for your help. Carmen >> >> 2018-08-21 20:56:57.824 o.a.s.m.StormMetricRegistry main [INFO] Starting >> metrics reporters... >> 2018-08-21 20:56:57.824 o.a.s.m.StormMetricRegistry main [INFO] >> Attempting to instantiate reporter class: >> org.apache.storm.metrics2.reporters.CsvReporter >> 2018-08-21 20:56:57.825 o.a.s.d.worker main [ERROR] Error on >> initialization of server mk-worker >> java.lang.RuntimeException: java.lang.ClassNotFoundException: >> org.apache.storm.metrics2.reporters.CsvReporter >> at org.apache.storm.utils.Utils.newInstance(Utils.java:187) >> ~[storm-core-1.2.2.jar:1.2.2] >> at >> org.apache.storm.metrics2.StormMetricRegistry.startReporter(StormMetricRegistry.java:117) >> ~[storm-core-1.2.2.jar:1.2.2] >> at >> org.apache.storm.metrics2.StormMetricRegistry.start(StormMetricRegistry.java:102) >> ~[storm-core-1.2.2.jar:1.2.2] >> at >> org.apache.storm.daemon.worker$fn__11300$exec_fn__2470__auto____11301.invoke(worker.clj:620) >> ~[storm-core-1.2.2.jar:1.2.2] >> at clojure.lang.AFn.applyToHelper(AFn.java:178) >> ~[clojure-1.7.0.jar:?] >> at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.7.0.jar:?] >> at clojure.core$apply.invoke(core.clj:630) ~[clojure-1.7.0.jar:?] >> at >> org.apache.storm.daemon.worker$fn__11300$mk_worker__11391.doInvoke(worker.clj:605) >> [storm-core-1.2.2.jar:1.2.2] >> at clojure.lang.RestFn.invoke(RestFn.java:512) >> [clojure-1.7.0.jar:?] >> at org.apache.storm.daemon.worker$_main.invoke(worker.clj:798) >> [storm-core-1.2.2.jar:1.2.2] >> at clojure.lang.AFn.applyToHelper(AFn.java:165) >> [clojure-1.7.0.jar:?] >> at clojure.lang.AFn.applyTo(AFn.java:144) [clojure-1.7.0.jar:?] >> at org.apache.storm.daemon.worker.main(Unknown Source) >> [storm-core-1.2.2.jar:1.2.2] >> Caused by: java.lang.ClassNotFoundException: >> org.apache.storm.metrics2.reporters.CsvReporter >> at >> jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:582) >> ~[?:?] >> at >> jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:190) >> ~[?:?] >> at java.lang.ClassLoader.loadClass(ClassLoader.java:499) ~[?:?] >> at java.lang.Class.forName0(Native Method) ~[?:?] >> at java.lang.Class.forName(Class.java:291) ~[?:?] >> at org.apache.storm.utils.Utils.newInstance(Utils.java:185) >> ~[storm-core-1.2.2.jar:1.2.2] >> ... 12 more >> 2018-08-21 20:56:57.834 STDERR Thread-1 [INFO] [3.554s][trace][gc,region >> ] G1HR ALLOC(EDEN) [0x000000063dc00000, 0x000000063dc00000, >> 0x000000063e000000] >> 2018-08-21 20:56:57.834 o.a.s.util main [ERROR] Halting process: ("Error >> on initialization") >> java.lang.RuntimeException: ("Error on initialization") >> >
