[jira] [Created] (STORM-2418) add proper log message on metrics server fails/absent

["Sree Vaddi (JIRA)" <ji...@apache.org>]

Sree Vaddi created STORM-2418:
---------------------------------

             Summary: add proper log message on metrics server fails/absent
                 Key: STORM-2418
                 URL: https://issues.apache.org/jira/browse/STORM-2418
             Project: Apache Storm
          Issue Type: Bug
          Components: storm-metrics, storm-opentsdb
    Affects Versions: 0.10.0
         Environment: storm 0.10.0

            Reporter: Sree Vaddi


my metrics consumer writes to opentsdb server.
when this server went down, i see the following error message in my storm jobs.
which is very misleading.
create a ticket, so we can address this in future versions better.

{code:language=java}
2017-03-16 01:22:43.648 b.s.util [ERROR] Async loop died!
java.lang.RuntimeException: java.lang.ClassCastException: java.lang.Object cannot be cast to java.lang.Iterable
	at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:135) ~[storm-core-0.10.0.jar:0.10.0]
	at backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:106) ~[storm-core-0.10.0.jar:0.10.0]
	at backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:80) ~[storm-core-0.10.0.jar:0.10.0]
	at backtype.storm.daemon.executor$fn__5694$fn__5707$fn__5758.invoke(executor.clj:819) ~[storm-core-0.10.0.jar:0.10.0]
	at backtype.storm.util$async_loop$fn__545.invoke(util.clj:479) [storm-core-0.10.0.jar:0.10.0]
	at clojure.lang.AFn.run(AFn.java:22) [clojure-1.6.0.jar:?]
	at java.lang.Thread.run(Thread.java:745) [?:1.8.0_45]
Caused by: java.lang.ClassCastException: java.lang.Object cannot be cast to java.lang.Iterable
	at backtype.storm.util$get_iterator.invoke(util.clj:929) ~[storm-core-0.10.0.jar:0.10.0]
	at backtype.storm.daemon.executor$mk_task_receiver$fn__5615.invoke(executor.clj:432) ~[storm-core-0.10.0.jar:0.10.0]
	at backtype.storm.disruptor$clojure_handler$reify__5189.onEvent(disruptor.clj:58) ~[storm-core-0.10.0.jar:0.10.0]
	at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:127) ~[storm-core-0.10.0.jar:0.10.0]
	... 6 more
{code}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)