src/main/java/com/infochimps/elasticsearch/ElasticSearchStreamingOutputFormat.java in wonderdog-0.0.1 vs src/main/java/com/infochimps/elasticsearch/ElasticSearchStreamingOutputFormat.java in wonderdog-0.0.2
- old
+ new
@@ -46,10 +46,10 @@
private static final String ES_ID_FIELD_OPT = "elasticsearch.output.id.field";
private static final String ES_ID_FIELD = "_id";
private String idFieldName;
private static final String ES_BULK_SIZE_OPT = "elasticsearch.output.bulk_size";
- private static final String ES_BULK_SIZE = "100";
+ private static final String ES_BULK_SIZE = "1000";
private int bulkSize;
// Elasticsearch internal settings required to make a client
// connection.