ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Saikat Maitra <saikat.mai...@gmail.com>
Subject Re: Need IgniteConfiguration and XML at the same time? IgniteStormStreamer?
Date Wed, 05 Sep 2018 02:54:33 GMT
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 <mehmetozanguven@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/
>

Mime
View raw message