Updated Branches: refs/heads/trunk 08843202f -> 5210b3163
FLUME-2100. Increase default batchSize of Morphline Solr Sink. (Wolfgang Hoschek via Mike Percy) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/5210b316 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/5210b316 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/5210b316 Branch: refs/heads/trunk Commit: 5210b3163032e295d44416aa867cd5c5bbdb459a Parents: 0884320 Author: Mike Percy <[email protected]> Authored: Mon Jun 24 00:46:59 2013 -0700 Committer: Mike Percy <[email protected]> Committed: Mon Jun 24 00:46:59 2013 -0700 ---------------------------------------------------------------------- .../java/org/apache/flume/sink/solr/morphline/MorphlineSink.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/5210b316/flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineSink.java ---------------------------------------------------------------------- diff --git a/flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineSink.java b/flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineSink.java index ea637c4..1e52a66 100644 --- a/flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineSink.java +++ b/flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineSink.java @@ -37,7 +37,7 @@ import com.cloudera.cdk.morphline.api.Command; */ public class MorphlineSink extends AbstractSink implements Configurable { - private int maxBatchSize = 100; + private int maxBatchSize = 1000; private long maxBatchDurationMillis = 1000; private String handlerClass; private MorphlineHandler handler;
