Mailing-List: contact dev-help@ignite.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@ignite.apache.org
MIME-Version: 1.0
In-Reply-To: 
 <CAMzr4XW72bUrqJp1NMPGC93nUdUevGqtGqVdp5hB-ThhsF00qA@mail.gmail.com>
References: 
 <CAMzr4XX9B+Ushfa71zoW7xVG-0Uob19CZNcXJ2fTJwwMcz45Nw@mail.gmail.com>
	<CAAgW0dban=ye=hve8E=W7o5NWK7gS3mnCAAm3zxHbdzH9ShcPA@mail.gmail.com>
	<CAMzr4XWSS4yC2kFGOL95mz5UuWrRfoxz_ihtoG88ixpAFH9HqQ@mail.gmail.com>
	<42359F2E-F406-4951-8995-380E479C9B68@gmail.com>
	<CAMzr4XUGedB7JmM-7esyYfmktsHrXMS1bb6CrwJnWYx=GBWZOg@mail.gmail.com>
	<CAOKDqC_Qq5zj1n_aXEWofGXB10oxSkiUG34edM_MUPKYg7eVGA@mail.gmail.com>
	<CAMzr4XWgmpo0bWpTNbC1Aj4qCaLJpQCbRRzcNsAAzcE5RhYNGQ@mail.gmail.com>
	<CABthXtBVc-1fR+Zrw7vdEdwmMcA-aX2H7X_=fAeOjcN-eQp=iQ@mail.gmail.com>
	<CAOKDqC9QdUBFQ_wZwQFABARZcmuTJUJphGdSipc6kfNdSn_T8g@mail.gmail.com>
	<CAMzr4XW72bUrqJp1NMPGC93nUdUevGqtGqVdp5hB-ThhsF00qA@mail.gmail.com>
Date: Sat, 26 Sep 2015 15:54:03 +0200
Message-ID: 
 <CABthXtDdN=CdG5ryfWjj1b2t=18EvT-q8t+Jpz4_O+koaobhqQ@mail.gmail.com>
Subject: Re: After setting streamer and ignite,getting NULL
From: Gianfranco Murador <murador.gianfranco@gmail.com>
To: dev@ignite.apache.org
Content-Type: multipart/alternative; boundary=001a113ec5fe1301430520a6cc98

--001a113ec5fe1301430520a6cc98
Content-Type: text/plain; charset=UTF-8

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
>

--001a113ec5fe1301430520a6cc98--