Re: After setting streamer and ignite,getting NULL

Gian, is code for ignite-429 in master branch? On Mon, Sep 28, 2015 at 5:27 PM, chandresh pancholi < chandreshpancholi...@gmail.com> wrote: > Gian, > > Lets use this and modify our tests. I will push the code by tomorrow EOD. > > Thanks > Chandresh Pancholi > > On Mon, Sep 28, 2015 at 3:58 PM,

Re: After setting streamer and ignite,getting NULL

Yes, in mater branch of my fork. 2015-09-29 8:45 GMT+02:00 chandresh pancholi : > Gian, > > is code for ignite-429 in master branch? > > On Mon, Sep 28, 2015 at 5:27 PM, chandresh pancholi < > chandreshpancholi...@gmail.com> wrote: > > > Gian, > > > > Lets use

Re: After setting streamer and ignite,getting NULL

Gian, I have tested storm-integration code locally. Its working fine. On Tue, Sep 29, 2015 at 4:12 PM, Gianfranco Murador wrote: > Yes, in mater branch of my fork. > > 2015-09-29 8:45 GMT+02:00 chandresh pancholi < > chandreshpancholi...@gmail.com > >: > > > Gian, > > > >

Re: After setting streamer and ignite,getting NULL

Chandresh, I think that the suggestion of Roman is preferable, we can use the following code : Let me know if you have problems /** Start a simulated topology */ public void startTopology(StormStreamer stormStreamer) { MkClusterParam mkClusterParam = new MkClusterParam();

Re: After setting streamer and ignite,getting NULL

Gian, I have checked the code. It looks good. Just one little change make it 20 sec. /* Topology will run for 10sec */ Utils.sleep(2); 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: >

Re: After setting streamer and ignite,getting NULL

Dmitriy, In storm, topologies run continuously but in our Unit test we are running them only for 20sec. and this the way to do it in Storm. On Mon, Sep 28, 2015 at 2:08 AM, Dmitriy Setrakyan wrote: > On Sun, Sep 27, 2015 at 1:36 PM, chandresh pancholi < >

Re: After setting streamer and ignite,getting NULL

On Sun, Sep 27, 2015 at 1:43 PM, chandresh pancholi < chandreshpancholi...@gmail.com> wrote: > Dmitriy, > In storm, topologies run continuously but in our Unit test we are running > them only for 20sec. and this the way to do it in Storm. > I generally would avoid any sleep() calls at all. If

Re: After setting streamer and ignite,getting NULL

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

Re: After setting streamer and ignite,getting NULL

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 wrote: On Sun, Sep 27, 2015 at 1:36 PM,

Re: After setting streamer and ignite,getting NULL

Agree, Will check for some other solution and update!! On Mon, Sep 28, 2015 at 9:12 AM, Vishal Garg wrote: > 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

Re: After setting streamer and ignite,getting NULL

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

Re: After setting streamer and ignite,getting NULL

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 : > Here is the log file. > > Thanks > > On Sat, Sep 26, 2015 at 10:40 PM, Gianfranco Murador < >

Re: After setting streamer and ignite,getting NULL

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 stormStreamer = null; Ignite ignite =

Re: After setting streamer and ignite,getting NULL

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 : > Gian, > > I have

Re: After setting streamer and ignite,getting NULL

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: > >

Re: After setting streamer and ignite,getting NULL

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

Re: After setting streamer and ignite,getting NULL

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: >

Re: After setting streamer and ignite,getting NULL

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

Re: After setting streamer and ignite,getting NULL

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"

Re: After setting streamer and ignite,getting NULL

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 wrote: > Did you figure it out? Something related to your storm integration? > Vishal > > Sent from my

Re: After setting streamer and ignite,getting NULL

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 > wrote: > > Problem here is with Storm. Its making streamer object null once it goes > into submit topology. > >

Re: After setting streamer and ignite,getting NULL

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 wrote: > Hi Chandresh, > > See test suite class here, its based on annotations > >

Re: After setting streamer and ignite,getting NULL

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