Re: EvalFunc finish() closing connections prematurely

2013-03-26 Thread Jonathan Coveney
Sorry about not getting to this, Mike! Dmitry's idea is a good one. I still think that something is axing the connections, possible between different map slots on the same mapper. I would log very liberally and see what comes of it. And I'll try and carve out some time. 2013/3/26 Dmitriy Ryaboy

Re: EvalFunc finish() closing connections prematurely

2013-03-25 Thread Dmitriy Ryaboy
Mike, have you tried adding logging to any EvalFunc methods that communicate with Mongo to see which of them is calling it after finish() ? Are you sure something else doesn't close Mongo connection for you? On Fri, Mar 22, 2013 at 8:28 AM, Mike Sukmanowsky wrote: > Bump - any thoughts? > > > O

Re: EvalFunc finish() closing connections prematurely

2013-03-22 Thread Mike Sukmanowsky
Bump - any thoughts? On Mon, Mar 18, 2013 at 4:53 PM, Mike Sukmanowsky wrote: > Sure thing - here you go > https://gist.github.com/msukmanowsky/198c878e1deaf4e470a9 > > When initialized, the ParselyMetadataService creates a new Mongo and Jedis > instance which the EvalFunc queries using a publi

Re: EvalFunc finish() closing connections prematurely

2013-03-18 Thread Mike Sukmanowsky
Sure thing - here you go https://gist.github.com/msukmanowsky/198c878e1deaf4e470a9 When initialized, the ParselyMetadataService creates a new Mongo and Jedis instance which the EvalFunc queries using a public method fetch(). Instance of ParselyMetadataService also have a close() function which si

Re: EvalFunc finish() closing connections prematurely

2013-03-14 Thread Jonathan Coveney
Can you perhaps share more of your implementation? I can imagine a couple of things which would cause errors like this. Are you making sure that each instance of EvalFunc is dealing with a different connection? That's what I'd take a look at first...if that isn't the issue, I can look into how fin

EvalFunc finish() closing connections prematurely

2013-03-14 Thread Mike Sukmanowsky
Hi there, I have an EvalFunc which uses an internal class that opens up connections to a Redis and MongoDB server. This class has a close() method which closes connections to both Redis and MongoDB. In my EvalFunc implementation, I placed the close() method @Override public void finish()