lib/fluent/plugin/parser_netflow_v9.rb in fluent-plugin-netflowipfix-1.0.2 vs lib/fluent/plugin/parser_netflow_v9.rb in fluent-plugin-netflowipfix-1.1.0

@@ -217,10 +217,16 @@
 							#    event['sampling_algorithm'] ||= sampler['flow_sampler_mode']
 							#    event['sampling_interval'] ||= sampler['flow_sampler_random_interval']
 							#  end
 							#end
 
-							block.call(time, event)
+#							block.call(time, event)
+#							if (defined?(block)).nil?
+#								log.error "*** handle_flowset_data block is blank"
+#							else
+#							end
+							  block.call(time, event, host)
+
 						end # fields = array.read
 					end # def handle_flowset_data
 
 					# covers Netflow v9 and v10 (a.k.a IPFIX)
 					def is_sampler?(record)