Added an additional check.

corelight · May 17, 2022 · b4913fa · b4913fa
1 parent b2c5ffc
commit b4913fa
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/zeek2es.py b/zeek2es.py
@@ -442,7 +442,7 @@ def main(**args):
                     n = 0
 
             # We do this one last time to get rid of any remaining lines.
-            if n != 0:
+            if n != 0 and len(outstring) > 0:
                 sendbulk(args, outstring, es_index, filename)
     else:
         # This does everything the TSV version does, but for JSON
@@ -578,7 +578,7 @@ def main(**args):
                     n = 0
 
         # We send the last of the data to the ES server, if there is any left.
-        if n != 0:
+        if n != 0 and len(outstring) > 0:
             sendbulk(args, outstring, es_index, filename)
 
 # This deals with running as a script vs. cython.