----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/5333/#review8300 -----------------------------------------------------------
Mubarak, Thanks for the patch! Looks good, though I have one suggestion below. trunk/flume-ng-sdk/src/main/java/org/apache/flume/api/FailoverRpcClient.java <https://reviews.apache.org/r/5333/#comment17917> You should be setting the batchSize of the localClient also. If this is not set the batchSize is never passed to the actual client that does the Rpc writes. - Hari On 2012-06-02 18:12:37, Mubarak Seyed wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/5333/ > ----------------------------------------------------------- > > (Updated 2012-06-02 18:12:37) > > > Review request for Flume. > > > Summary > ------- > > FailoverRpcClient uses batchSize as local variable and it breaks the contract > for getBatchSize(). Consumer of FailoverRpcClient checks for getBatchSize() > to send events using appendBatch(List<Event>), since batchSize is initialized > with null, clients gets NPE. > > The fix is to remove the batchSize local variable in configureHosts() > > > This addresses bug FLUME-1226. > https://issues.apache.org/jira/browse/FLUME-1226 > > > Diffs > ----- > > > trunk/flume-ng-sdk/src/main/java/org/apache/flume/api/FailoverRpcClient.java > 1342144 > > Diff: https://reviews.apache.org/r/5333/diff > > > Testing > ------- > > Tested in lab environment. > > > Thanks, > > Mubarak > >
