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")
