Updated Branches: refs/heads/trunk 9fba39cb9 -> 58173b898
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/58173b89 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/58173b89 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/58173b89 Branch: refs/heads/trunk Commit: 58173b8983027124a61783b4326dee3347ab7552 Parents: 9fba39c Author: Mike Percy <[email protected]> Authored: Wed Jan 2 16:59:37 2013 -0800 Committer: Mike Percy <[email protected]> Committed: Wed Jan 2 16:59:37 2013 -0800 ---------------------------------------------------------------------- .../sink/elasticsearch/ElasticSearchSink.java | 4 +++- 1 files changed, 3 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/58173b89/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;
