lib/logstash/inputs/elasticsearch/aggregation.rb in logstash-input-elasticsearch-4.20.1 vs lib/logstash/inputs/elasticsearch/aggregation.rb in logstash-input-elasticsearch-4.20.2

@@ -28,17 +28,18 @@
           stud_try.try((@retries + 1).times) { yield }
         rescue => e
           error_details = {:message => e.message, :cause => e.cause}
           error_details[:backtrace] = e.backtrace if logger.debug?
           logger.error("Tried #{job_name} unsuccessfully", error_details)
+          false
         end
 
         def do_run(output_queue)
           logger.info("Aggregation starting")
           r = retryable(AGGREGATION_JOB) do
             @client.search(@agg_options)
           end
-          @plugin.push_hit(r, output_queue, 'aggregations')
+          @plugin.push_hit(r, output_queue, 'aggregations') if r
         end
       end
     end
   end
 end