From c676fad5b1e1b11905eab4e80577791192a0eaeb Mon Sep 17 00:00:00 2001 From: childe Date: Wed, 3 May 2017 17:04:25 +0800 Subject: [PATCH] bulk_actions --- .../main/java/com/ctrip/ops/sysdev/outputs/Elasticsearch.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hangout-output-plugins/hangout-output-plugins-elasticsearch/src/main/java/com/ctrip/ops/sysdev/outputs/Elasticsearch.java b/hangout-output-plugins/hangout-output-plugins-elasticsearch/src/main/java/com/ctrip/ops/sysdev/outputs/Elasticsearch.java index 3d22eb35..6724f47d 100644 --- a/hangout-output-plugins/hangout-output-plugins-elasticsearch/src/main/java/com/ctrip/ops/sysdev/outputs/Elasticsearch.java +++ b/hangout-output-plugins/hangout-output-plugins-elasticsearch/src/main/java/com/ctrip/ops/sysdev/outputs/Elasticsearch.java @@ -124,7 +124,7 @@ private void initESClient() throws NumberFormatException { } }); - int bulkActions = config.containsKey("bulk_action") ? (int) config.get("bulk_action") : BULKACTION; + int bulkActions = config.containsKey("bulk_actions") ? (int) config.get("bulk_actions") : BULKACTION; int bulkSize = config.containsKey("bulk_size") ? (int) config.get("bulk_size") : BULKSIZE; int flushInterval = config.containsKey("flush_interval") ? (int) config.get("flush_interval") : FLUSHINTERVAL; int concurrentRequests = config.containsKey("concurrent_requests") ? (int) config.get("concurrent_requests") : CONCURRENTREQSIZE;