Updated Branches: refs/heads/flume-1.4 8c8e1e997 -> baf97df59
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/baf97df5 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/baf97df5 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/baf97df5 Branch: refs/heads/flume-1.4 Commit: baf97df5991542b449b19a00cc2bc3c60d723e01 Parents: 8c8e1e9 Author: Mike Percy <[email protected]> Authored: Mon Jun 24 00:46:59 2013 -0700 Committer: Mike Percy <[email protected]> Committed: Mon Jun 24 00:48:53 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/baf97df5/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;
