Chandresh, Generally sleep in tests is not a good idea. Will try to look into your test this week, see if we can avoid it. Meanwhile you can look at how storm does its own unit testing if you could find one? Vishal
Sent from my iPhone > On Sep 27, 2015, at 8:23 PM, Roman <rsht...@yahoo.com.INVALID> wrote: > > I also have concerns about this sleep().Storm has testing facilities you can > use for your test. How about Testing.withSimulatedTimeLocalCluster()? > Roman > > > > On Monday, September 28, 2015 5:39 AM, Dmitriy Setrakyan > <dsetrak...@apache.org> wrote: > > > On Sun, Sep 27, 2015 at 1:36 PM, chandresh pancholi < > chandreshpancholi...@gmail.com> wrote: > >> Gian, >> I have checked the code. It looks good. >> Just one little change make it 20 sec. >> >> /* Topology will run for 10sec */ >> Utils.sleep(20000); > > Hm... Can someone explain what is this sleep() for? > > >> >> >> >> On Sun, Sep 27, 2015 at 4:30 PM, Gianfranco Murador < >> murador.gianfra...@gmail.com> wrote: >> >>> 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 < >>> chandreshpancholi...@gmail.com >>>> : >>> >>>> Here is the log file. >>>> >>>> Thanks >>>> >>>> On Sat, Sep 26, 2015 at 10:40 PM, Gianfranco Murador < >>>> murador.gianfra...@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 < >>>>> chandreshpancholi...@gmail.com>: >>>>> >>>>>> Gian, >>>>>> Its still giving "Ouch! Argument cannot be null: streamer" >>>>>> >>>>>> On Sat, Sep 26, 2015 at 7:24 PM, Gianfranco Murador < >>>>>> murador.gianfra...@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 < >>>>>>> chandreshpancholi...@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 < >>>>>>>> avinogra...@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.gianfra...@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 < >>>>>>>>>> chandreshpancholi...@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 < >>>>>>>>>>> avinogra...@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 < >>>>>>>>>>>> chandreshpancholi...@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 < >>>>>>> gargv...@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 < >>>>>>>>>>>>>>> chandreshpancholi...@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....@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 < >>>>>>>>>>>>>>>> chandreshpancholi...@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.panch...@flipkart.com >>>>>>>>>>>>>>>>> Contact:08951803660 >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> >>>>>>>>>>>>>>> -- >>>>>>>>>>>>>>> Chandresh Pancholi >>>>>>>>>>>>>>> Senior Software Engineer >>>>>>>>>>>>>>> Flipkart.com >>>>>>>>>>>>>>> Email-id:chandresh.panch...@flipkart.com >>>>>>>>>>>>>>> Contact:08951803660 >>>>>>>>>>>>> >>>>>>>>>>>>> >>>>>>>>>>>>> >>>>>>>>>>>>> -- >>>>>>>>>>>>> Chandresh Pancholi >>>>>>>>>>>>> Senior Software Engineer >>>>>>>>>>>>> Flipkart.com >>>>>>>>>>>>> Email-id:chandresh.panch...@flipkart.com >>>>>>>>>>>>> Contact:08951803660 >>>>>>>>>>> >>>>>>>>>>> >>>>>>>>>>> >>>>>>>>>>> -- >>>>>>>>>>> Chandresh Pancholi >>>>>>>>>>> Senior Software Engineer >>>>>>>>>>> Flipkart.com >>>>>>>>>>> Email-id:chandresh.panch...@flipkart.com >>>>>>>>>>> Contact:08951803660 >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> -- >>>>>>>> Chandresh Pancholi >>>>>>>> Senior Software Engineer >>>>>>>> Flipkart.com >>>>>>>> Email-id:chandresh.panch...@flipkart.com >>>>>>>> Contact:08951803660 >>>>>> >>>>>> >>>>>> >>>>>> -- >>>>>> Chandresh Pancholi >>>>>> Senior Software Engineer >>>>>> Flipkart.com >>>>>> Email-id:chandresh.panch...@flipkart.com >>>>>> Contact:08951803660 >>>> >>>> >>>> >>>> -- >>>> Chandresh Pancholi >>>> Senior Software Engineer >>>> Flipkart.com >>>> Email-id:chandresh.panch...@flipkart.com >>>> Contact:08951803660 >> >> >> >> -- >> Chandresh Pancholi >> Senior Software Engineer >> Flipkart.com >> Email-id:chandresh.panch...@flipkart.com >> Contact:08951803660 > >
