Fix bug of #4

RickyHuo · Mar 26, 2018 · c7b1223 · c7b1223
1 parent 342807f
commit c7b1223
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/com/sina/bip/hangout/outputs/Clickhouse.java b/src/main/java/com/sina/bip/hangout/outputs/Clickhouse.java
@@ -67,7 +67,7 @@ private void eventInsert(Map event) throws Exception {
     private void eventInsert(Map event, int eventSize) throws Exception {
 
         this.events.add(event);
-        if (this.events.size() == eventSize) {
+        if (this.events.size() >= eventSize) {
             log.info("Insert bulk start, number: " + this.bulkNum);
             this.formatParse.bulkInsert(events);
             log.info("Insert bulk end, number: " + this.bulkNum);