FLUME-1398: Concurrency improvements to Async hbase sink
Review Request #6170 - Created July 27, 2012 and submitted
Made some concurrency modifications to Async hbase sink. Also, now backs off only if no events were fetched from channel - like Avro sink.
Exising unit tests pass. Functional testing done.
Posted (July 27, 2012, 3:09 p.m.)
Hi Hari, thanks you for your patch, I just do have one question and one small suggestion:
I believe that assigning zero to variable "i" might be done here only once.
Just a question here - do we really need to create new callback objects here each time? Wouldn't be possible to reuse them and spare the time on creating objects?
Review request changed
Updated (July 27, 2012, 5:09 p.m.)
- changed from pending to submitted