Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix(query/stdlib/influxdb): return error on point explosion (#12774)

pull/12778/head
Lorenzo Affetti 2019-03-20 15:45:31 +01:00 committed by GitHub
parent adbfddb0ef
commit d18c6e5ffe
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
query/stdlib/influxdata/influxdb/to.go
View File

@ -589,6 +589,9 @@ func writeTable(t *ToTransformation, tbl flux.Table) error {
}
}
points, err = tsdb.ExplodePoints(*orgID, *bucketID, points)
if err != nil {
return err
}
return d.PointsWriter.WritePoints(context.TODO(), points)
})
}