Updated Branches: refs/heads/flume-1.4 5e8fbcc7f -> 977f1faf9
FLUME-1076. Sink default batch sizes vary wildly. (Roshan Naik 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/977f1faf Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/977f1faf Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/977f1faf Branch: refs/heads/flume-1.4 Commit: 977f1faf92356cecfa246518514ecd074abf9d39 Parents: 5e8fbcc Author: Mike Percy <[email protected]> Authored: Wed Jan 2 16:59:37 2013 -0800 Committer: Mike Percy <[email protected]> Committed: Wed Jan 2 17:03:33 2013 -0800 ---------------------------------------------------------------------- .../sink/elasticsearch/ElasticSearchSink.java | 4 +++- 1 files changed, 3 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/977f1faf/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSink.java ---------------------------------------------------------------------- diff --git a/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSink.java b/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSink.java index 26bad20..1b3db14 100644 --- a/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSink.java +++ b/flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSink.java @@ -96,7 +96,9 @@ public class ElasticSearchSink extends AbstractSink implements Configurable { private boolean isLocal = false; private final CounterGroup counterGroup = new CounterGroup(); - private int batchSize; + private static final int defaultBatchSize = 100; + + private int batchSize = defaultBatchSize; private long ttlMs = DEFAULT_TTL; private String clusterName = DEFAULT_CLUSTER_NAME; private String indexName = DEFAULT_INDEX_NAME;
