You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by mp...@apache.org on 2013/01/03 02:03:29 UTC
git commit: FLUME-1076. Sink default batch sizes vary wildly.
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 <mp...@apache.org>
Authored: Wed Jan 2 16:59:37 2013 -0800
Committer: Mike Percy <mp...@apache.org>
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;