JMSSpout open() is throwing classCastException #32
Description
Getting a class cast on
Integer topologyTimeout = (Integer)conf.get("topology.message.timeout.secs");
in JmsSpout.java
This should be similar to;
Integer topologyTimeout = Integer.parseInt(String.valueOf(conf.get("topology.message.timeout.secs")));