diff --git a/lib/logstash/outputs/influxdb.rb b/lib/logstash/outputs/influxdb.rb index 9d5f0b9..3f8160b 100644 --- a/lib/logstash/outputs/influxdb.rb +++ b/lib/logstash/outputs/influxdb.rb @@ -187,7 +187,7 @@ def flush(events, database, teardown = false) def dowrite(events, database) begin - @influxdbClient.write_points(events, @time_precision, @retention_policy, @db ) + @influxdbClient.write_points(events, @time_precision, @retention_policy, database ) rescue InfluxDB::AuthenticationError => ae @logger.warn("Authentication Error while writing to InfluxDB", :exception => ae) rescue InfluxDB::ConnectionError => ce