Spouts : load results with a non-blocking call

[jnioche]

We currently block the nextTuple when executing an Elasticsearch query and as such prevent ack/fails to happen. Instead, we should execute the ES query with a non-blocking call and return as soon as possible. This would possibly require the access to the buffer to be synchronized and an additional check that we are not already querying.

[XciD]

I've done something similar on my spouts, as you say, in order to don't block nextTuple, ackand fail methods

I will try to generify

[jnioche]

That would be great. Thanks

On 14 Nov 2016 11:38, "XciD" notifications@github.com wrote:

I've done something similar on my spouts, as you say, in order to don't
block nextTuple, ackand fail methods

I will try to generify

—
You are receiving this because you were assigned.
Reply to this email directly, view it on GitHub
#371 (comment),
or mute the thread
https://github.com/notifications/unsubscribe-auth/AANUz7pU-_2mAVPigeaOOUHpliAaz7o2ks5q-DoZgaJpZM4KmIPs
.