Hi, I am not sure if this is useful, I once had similar issue. Are you including storm-core dependency in your project? flink-storm dependency doesn't need any specific storm-core dependency.
Just including flink-storm and removing storm-core dependency worked for me. This has more information, https://flink.apache.org/news/2015/12/11/storm-compatibility.html Thanks, Naveen On Mon, Mar 14, 2016 at 3:03 PM, Sharma, Samiksha <samiksha.sha...@here.com> wrote: > Hi, > > I am converting a storm topology to Flink-storm topology using the > flink-storm dependency. When I run my code the FlinkTopologyBuilder > eventually calls createTopology method in TopologyBuilder and throws the > error at the following highlighted line:- > > > public StormTopology createTopology() { > > Map<String, Bolt> boltSpecs = new HashMap<String, Bolt>(); > > Map<String, SpoutSpec> spoutSpecs = new HashMap<String, > SpoutSpec>(); > > for(String boltId: _bolts.keySet()) { > > IRichBolt bolt = _bolts.get(boltId); > > ComponentCommon common = getComponentCommon(boltId, bolt); > > boltSpecs.put(boltId, new > Bolt(ComponentObject.serialized_java(Utils.serialize(bolt)), common)); > > } > > > Exception in thread "main" java.lang.ExceptionInInitializerError > > at > backtype.storm.topology.TopologyBuilder.createTopology(TopologyBuilder.java:106) > > at > org.apache.flink.storm.api.FlinkTopologyBuilder.createTopology(FlinkTopologyBuilder.java:82) > > at > com.medio.services.avalanche.storm.common.BaseTopology.deploy(BaseTopology.java:118) > > at > com.medio.services.avalanche.realtime.eventcounter.EventCounterTopology.main(EventCounterTopology.java:18) > > Caused by: java.lang.RuntimeException: Found multiple defaults.yaml > resources. You're probably bundling the Storm jars with your topology jar. > [jar:file:/Users/samsharm/.m2/repository/storm/storm-core/ > 0.9.0.1/storm-core-0.9.0.1.jar!/defaults.yaml, > jar:file:/Users/samsharm/.m2/repository/org/apache/storm/storm-core/0.9.4/storm-core-0.9.4.jar!/defaults.yaml] > > at backtype.storm.utils.Utils.findAndReadConfigFile(Utils.java:133) > > at backtype.storm.utils.Utils.readDefaultConfig(Utils.java:160) > > at backtype.storm.utils.Utils.readStormConfig(Utils.java:184) > > at backtype.storm.utils.Utils.<clinit>(Utils.java:71) > > ... 4 more > > > > Looks like some bad storm dependencies are getting in the project. May I > request to please assist what might be going wrong? > > > > Thanks > > Best Regards > > Samiksha > > >
