ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gianfranco Murador <murador.gianfra...@gmail.com>
Subject Re: After setting streamer and ignite,getting NULL
Date Sun, 27 Sep 2015 11:00:13 GMT
Chandresh,  we're ready to do a pull request. Look here:
https://github.com/murador/ignite/tree/IGNITE-429/modules/storm

2015-09-27 8:49 GMT+02:00 chandresh pancholi <chandreshpancholi007@gmail.com
>:

> Here is the log file.
>
> Thanks
>
> On Sat, Sep 26, 2015 at 10:40 PM, Gianfranco Murador <
> murador.gianfranco@gmail.com> wrote:
>
>> Chan,
>>  I can run the test succefully, but sometimes I get this error:
>> Caused by: class org.apache.ignite.spi.IgniteSpiException: Failed to add
>> node to topology because remote node is configured to use loopback
>> address,
>> but local node is not (consider changing 'localAddress' configuration
>> parameter).
>>
>> can you send the log file?
>> Regards, Gianfranco
>>
>>
>>
>> 2015-09-26 17:13 GMT+02:00 chandresh pancholi <
>> chandreshpancholi007@gmail.com>:
>>
>> > Gian,
>> > Its still giving "Ouch! Argument cannot be null: streamer"
>> >
>> > On Sat, Sep 26, 2015 at 7:24 PM, Gianfranco Murador <
>> > murador.gianfranco@gmail.com> wrote:
>> >
>> > > Chan,
>> > >  I've fixed some issue, please take a look here:
>> > >
>> > >
>> >
>> https://github.com/murador/ignite/blob/IGNITE-429/modules/storm/src/test/java/org/apache/ignite/stream/storm/StormIgniteStreamerSelfTest.java
>> > >
>> > > 2015-09-26 8:29 GMT+02:00 chandresh pancholi <
>> > > chandreshpancholi007@gmail.com
>> > > >:
>> > >
>> > > > Gian,
>> > > >
>> > > > I have followed instructions given by you. I instantiate
>> > > IgniteDateStreamer
>> > > > and ignite in prepare() method of bolt. but getting "*Cache doesn't
>> > > > exist*".
>> > > >
>> > > > Code snippet from stormStreamer class in prepare() method
>> > > >
>> > > > StormStreamer<String, String, String> stormStreamer = null;
>> > > >
>> > > > Ignite ignite = Ignition.start();
>> > > >
>> > > > System.out.println(" ignite ====== "+ignite.toString());
>> > > >
>> > > > try(IgniteDataStreamer<String, String> stmr =
>> > > > ignite.dataStreamer("cache-0")) {
>> > > >
>> > > >     stormStreamer = new StormStreamer<>();
>> > > >
>> > > >     IgniteCache<String, String> cache = ignite.cache("cache-0");
>> > > >
>> > > >     stmr.allowOverwrite(true);
>> > > >
>> > > >     /*  Set ignite instance */
>> > > >     stormStreamer.setIgnite(ignite);
>> > > >
>> > > >     /* Set streamer instance */
>> > > >     stormStreamer.setStreamer(stmr);
>> > > >
>> > > >     /* set thread count */
>> > > >     setThreads(5);
>> > > >
>> > > > }
>> > > >
>> > > >
>> > > >
>> > > > On Thu, Sep 24, 2015 at 4:19 PM, Anton Vinogradov <
>> > > > avinogradov@gridgain.com>
>> > > > wrote:
>> > > >
>> > > > > Chandresh,
>> > > > > As far as understand IBolt implementation should setup all
>> external
>> > > > > connections at .prepare() method.
>> > > > > So, better way is to get existing Ignite instance or create new
at
>> > > > > .prepare()
>> > > > > method.
>> > > > >
>> > > > >
>> > > > > On Thu, Sep 24, 2015 at 10:55 AM, Gianfranco Murador <
>> > > > > murador.gianfranco@gmail.com> wrote:
>> > > > >
>> > > > > > Chandresh,
>> > > > > > I will launch the unit test later this week , if the problem
>> > > persists.
>> > > > I
>> > > > > > think that you should instantiate Ignite through the start()
>> method
>> > > of
>> > > > > > Ignition class
>> > > > > > and retrieve the Ignite cache specifying a name for the
default
>> > > cache.
>> > > > > You
>> > > > > > should provide a name also for data streamer, not passing
null.
>> > > > > > Could you do this and run again the unit test ?
>> > > > > > Thank you,
>> > > > > > Regards,
>> > > > > >  Gianfranco
>> > > > > >
>> > > > > >
>> > > > > > 2015-09-24 5:40 GMT+02:00 chandresh pancholi <
>> > > > > > chandreshpancholi007@gmail.com
>> > > > > > >:
>> > > > > >
>> > > > > > > Anton,
>> > > > > > >
>> > > > > > > Clone this repo https://github.com/chandresh-pancholi/ignite
>> and
>> > > run
>> > > > > > this
>> > > > > > > class
>> > > > > > >
>> > > > > > >
>> > > > > >
>> > > > >
>> > > >
>> > >
>> >
>> https://github.com/chandresh-pancholi/ignite/blob/master/modules/storm/src/test/java/org/apache/ignite/stream/storm/IgniteStormStreamerSelfTestSuite.java
>> > > > > > >
>> > > > > > > You will get the Error saying "Oouch,Argument is Null"
for
>> > > > > getStreamer().
>> > > > > > >
>> > > > > > > On Wed, Sep 23, 2015 at 9:46 PM, Anton Vinogradov <
>> > > > > > > avinogradov@gridgain.com>
>> > > > > > > wrote:
>> > > > > > >
>> > > > > > > > Chandresh,
>> > > > > > > > I'm trying to analize problem.
>> > > > > > > > Could you please provide more details and explain
>> step-by-step
>> > > how
>> > > > > can
>> > > > > > I
>> > > > > > > > reproduce problem?
>> > > > > > > >
>> > > > > > > > On Tue, Sep 22, 2015 at 11:06 PM, chandresh pancholi
<
>> > > > > > > > chandreshpancholi007@gmail.com> wrote:
>> > > > > > > >
>> > > > > > > > > Not yet.
>> > > > > > > > > Still doing brainstorming why StormStreamer
object is
>> getting
>> > > > NULLL
>> > > > > > > > > in-spite setting up ignite and streamer instances.
>> > > > > > > > >
>> > > > > > > > > On Tue, Sep 22, 2015 at 7:22 PM, Vishal Garg
<
>> > > gargvish@gmail.com
>> > > > >
>> > > > > > > wrote:
>> > > > > > > > >
>> > > > > > > > > > Did you figure it out? Something related
to your storm
>> > > > > integration?
>> > > > > > > > > > Vishal
>> > > > > > > > > >
>> > > > > > > > > > Sent from my iPhone
>> > > > > > > > > >
>> > > > > > > > > > > On Sep 22, 2015, at 4:50 AM, chandresh
pancholi <
>> > > > > > > > > > chandreshpancholi007@gmail.com> wrote:
>> > > > > > > > > > >
>> > > > > > > > > > > Problem here is with Storm. Its
making streamer object
>> > null
>> > > > > once
>> > > > > > it
>> > > > > > > > > goes
>> > > > > > > > > > > into submit topology.
>> > > > > > > > > > >
>> > > > > > > > > > > On Mon, Sep 21, 2015 at 7:13 PM,
Lalit Kumar Jha <
>> > > > > > > > lalitj.dev@gmail.com
>> > > > > > > > > >
>> > > > > > > > > > > wrote:
>> > > > > > > > > > >
>> > > > > > > > > > >> Hi Chandresh,
>> > > > > > > > > > >>
>> > > > > > > > > > >> See test suite class here,
its based on annotations
>> > > > > > > > > > >>
>> > > > > > > > > > >>
>> > > > > > > > > >
>> > > > > > > > >
>> > > > > > > >
>> > > > > > >
>> > > > > >
>> > > > >
>> > > >
>> > >
>> >
>> https://github.com/sylentprayer/ignite/blob/ignite-530/modules/twitter/src/test/java/org/apache/ignite/stream/twitter/IgniteTwitterStreamerTestSuite.java
>> > > > > > > > > > >>
>> > > > > > > > > > >> No code required in class body.
>> > > > > > > > > > >>
>> > > > > > > > > > >> On Mon, Sep 21, 2015 at 6:24
PM, chandresh pancholi <
>> > > > > > > > > > >> chandreshpancholi007@gmail.com>
wrote:
>> > > > > > > > > > >>
>> > > > > > > > > > >>> Hi Gian/Vishal/Lalit,
>> > > > > > > > > > >>>
>> > > > > > > > > > >>> You guys have worked on
Streamer integration with
>> > > Ignite. I
>> > > > > am
>> > > > > > > > > working
>> > > > > > > > > > on
>> > > > > > > > > > >>> Storm-ignite integration.
>> > > > > > > > > > >>>
>> > > > > > > > > > >>> I am setting up setStreamer()
and setIgnite() in
>> Test
>> > > class
>> > > > > and
>> > > > > > > > > sending
>> > > > > > > > > > >>> this object to setBolt()
method.
>> > > > > > > > > > >>>
>> > > > > > > > > > >>> When i try to read via
gettreamer() and getIgnite()
>> i
>> > am
>> > > > > > getting
>> > > > > > > > > NULL.
>> > > > > > > > > > I
>> > > > > > > > > > >> am
>> > > > > > > > > > >>> trying to find out why
is it happening but No Luck.
>> > > > > > > > > > >>>
>> > > > > > > > > > >>> If any one of you find
some time and look into the
>> code
>> > > and
>> > > > > > help
>> > > > > > > me
>> > > > > > > > > to
>> > > > > > > > > > >>> resolve this. It would
be great.
>> > > > > > > > > > >>>
>> > > > > > > > > > >>> Git : https://github.com/chandresh-pancholi/ignite
>> > > > > > > > > > >>> Module : storm
>> > > > > > > > > > >>>
>> > > > > > > > > > >>> --
>> > > > > > > > > > >>> Chandresh Pancholi
>> > > > > > > > > > >>> Senior Software Engineer
>> > > > > > > > > > >>> Flipkart.com
>> > > > > > > > > > >>> Email-id:chandresh.pancholi@flipkart.com
>> > > > > > > > > > >>> Contact:08951803660
>> > > > > > > > > > >
>> > > > > > > > > > >
>> > > > > > > > > > >
>> > > > > > > > > > > --
>> > > > > > > > > > > Chandresh Pancholi
>> > > > > > > > > > > Senior Software Engineer
>> > > > > > > > > > > Flipkart.com
>> > > > > > > > > > > Email-id:chandresh.pancholi@flipkart.com
>> > > > > > > > > > > Contact:08951803660
>> > > > > > > > > >
>> > > > > > > > >
>> > > > > > > > >
>> > > > > > > > >
>> > > > > > > > > --
>> > > > > > > > > Chandresh Pancholi
>> > > > > > > > > Senior Software Engineer
>> > > > > > > > > Flipkart.com
>> > > > > > > > > Email-id:chandresh.pancholi@flipkart.com
>> > > > > > > > > Contact:08951803660
>> > > > > > > > >
>> > > > > > > >
>> > > > > > >
>> > > > > > >
>> > > > > > >
>> > > > > > > --
>> > > > > > > Chandresh Pancholi
>> > > > > > > Senior Software Engineer
>> > > > > > > Flipkart.com
>> > > > > > > Email-id:chandresh.pancholi@flipkart.com
>> > > > > > > Contact:08951803660
>> > > > > > >
>> > > > > >
>> > > > >
>> > > >
>> > > >
>> > > >
>> > > > --
>> > > > Chandresh Pancholi
>> > > > Senior Software Engineer
>> > > > Flipkart.com
>> > > > Email-id:chandresh.pancholi@flipkart.com
>> > > > Contact:08951803660
>> > > >
>> > >
>> >
>> >
>> >
>> > --
>> > Chandresh Pancholi
>> > Senior Software Engineer
>> > Flipkart.com
>> > Email-id:chandresh.pancholi@flipkart.com
>> > Contact:08951803660
>> >
>>
>
>
>
> --
> Chandresh Pancholi
> Senior Software Engineer
> Flipkart.com
> Email-id:chandresh.pancholi@flipkart.com
> Contact:08951803660
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message