diff --git a/database/influxdb/database.go b/database/influxdb/database.go index 0ca036b8..b1ee8dbf 100644 --- a/database/influxdb/database.go +++ b/database/influxdb/database.go @@ -114,7 +114,7 @@ func (conn *Connection) addWorker() { // create new batch timer.Reset(batchTimeout) if bp, err = client.NewBatchPoints(bpConfig); err != nil { - log.Fatal(err) + log.Print(err) } } bp.AddPoint(point) @@ -134,7 +134,7 @@ func (conn *Connection) addWorker() { log.Println("saving", len(bp.Points()), "points") if err = conn.client.Write(bp); err != nil { - log.Fatal(err) + log.Print(err) } writeNow = false bp = nil