bulk_actions

childe · May 3, 2017 · c676fad · c676fad
1 parent 9218e6a
commit c676fad
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...utput-plugins-elasticsearch/src/main/java/com/ctrip/ops/sysdev/outputs/Elasticsearch.java b/...utput-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;