Hi, StormStreamer already creates Ignite instance as part of start() method. In your example since multiple thread is trying to create ignite instances you are getting the exception of "Ignite already started".
Please take a look into the below sample test implementation of StormStreamer. https://github.com/apache/ignite/blob/master/modules/storm/src/test/java/org/apache/ignite/stream/storm/StormIgniteStreamerSelfTest.java Also can you please share your Ignite configuration xml file. Regards, Saikat On Tue, Sep 4, 2018 at 8:36 AM, monstereo <mehmetozangu...@gmail.com> wrote: > I want to integrate ignite with storm via ignite-storm dependency > Because of Storm works with Threads, I had to use: > > *Ignite node =Ignition.getOrStart(...),* > > and this method only takes IgniteConfiguration instance. Here is the method > declaration: > > *public static Ignite getOrStart(IgniteConfiguration cfg) throws > IgniteException * > > If I do not use this method, I will get Ignite already started exception. > > Now, I want to set ignite bolt via: > > igniteStormStreamer = new StormStreamer<>(); > ... > *builder.setBolt("igniteBolt", > igniteStormStreamer).shuffleGrouping("OtherBolt");* > > and this igniteStormStreamer needs > *igniteStormStreamer.setIgniteConfigFile(getProperties().getProperty(" > ignite.config"));* > > however, when i put class path to this ignite.config property, gives me > error: > > *Caused by: org.apache.ignite.IgniteException: Spring XML configuration > path > is invalid: apacheIgnite.CreateIgniteConfiguration. Note that this path > should be either absolute or a relative local file system path, relative to > META-INF in classpath or valid URL to IGNITE_HOME.* > > when i put xml file to this ignite.config property, gives me error: > *8137 [Thread-26-igniteBolt-executor[5 5]] ERROR o.a.s.d.executor - > java.lang.IncompatibleClassChangeError: Implementing class* > > > how can i should this issue? > > > > > > > > > > > -- > Sent from: http://apache-ignite-users.70518.x6.nabble.com/ >
